Class BlobChangefeedAsyncClient
- java.lang.Object
-
- com.azure.storage.blob.changefeed.BlobChangefeedAsyncClient
-
public class BlobChangefeedAsyncClient extends Object
This class provides a client that contains all operations that apply to Azure Storage Blob changefeed.- See Also:
BlobChangefeedClientBuilder
-
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description BlobChangefeedPagedFlux
getEvents()
Returns a reactive Publisher emitting all the changefeed events for this account lazily as needed.BlobChangefeedPagedFlux
getEvents(String cursor)
Returns a reactive Publisher emitting all the changefeed events for this account lazily as needed.BlobChangefeedPagedFlux
getEvents(OffsetDateTime startTime, OffsetDateTime endTime)
Returns a reactive Publisher emitting all the changefeed events for this account lazily as needed.
-
-
-
Method Detail
-
getEvents
public BlobChangefeedPagedFlux getEvents()
Returns a reactive Publisher emitting all the changefeed events for this account lazily as needed.Changefeed events are returned in approximate temporal order.
For more information, see the Azure Docs.
Code Samples
client.getEvents().subscribe(event -> System.out.printf("Topic: %s, Subject: %s%n", event.getTopic(), event.getSubject()));
- Returns:
- A reactive response emitting the changefeed events.
-
getEvents
public BlobChangefeedPagedFlux getEvents(OffsetDateTime startTime, OffsetDateTime endTime)
Returns a reactive Publisher emitting all the changefeed events for this account lazily as needed.Changefeed events are returned in approximate temporal order.
For more information, see the Azure Docs.
Code Samples
OffsetDateTime startTime = OffsetDateTime.MIN; OffsetDateTime endTime = OffsetDateTime.now(); client.getEvents(startTime, endTime).subscribe(event -> System.out.printf("Topic: %s, Subject: %s%n", event.getTopic(), event.getSubject()));
- Parameters:
startTime
- Filters the results to return events approximately after the start time. Note: A few events belonging to the previous hour can also be returned. A few events belonging to this hour can be missing; to ensure all events from the hour are returned, round the start time down by an hour.endTime
- Filters the results to return events approximately before the end time. Note: A few events belonging to the next hour can also be returned. A few events belonging to this hour can be missing; to ensure all events from the hour are returned, round the end time up by an hour.- Returns:
- A reactive response emitting the changefeed events.
-
getEvents
public BlobChangefeedPagedFlux getEvents(String cursor)
Returns a reactive Publisher emitting all the changefeed events for this account lazily as needed.Changefeed events are returned in approximate temporal order.
For more information, see the Azure Docs.
Code Samples
String cursor = "cursor"; client.getEvents(cursor).subscribe(event -> System.out.printf("Topic: %s, Subject: %s%n", event.getTopic(), event.getSubject()));
- Parameters:
cursor
- Identifies the portion of the events to be returned with the next get operation. Events that take place after the event identified by the cursor will be returned.- Returns:
- A reactive response emitting the changefeed events.
-
-