public class BlobChangefeedAsyncClient extends Object
BlobChangefeedClientBuilder
Modifier and Type | Method and Description |
---|---|
BlobChangefeedPagedFlux |
getEvents()
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.
|
BlobChangefeedPagedFlux |
getEvents(String cursor)
Returns a reactive Publisher emitting all the changefeed events for this account lazily as needed.
|
public BlobChangefeedPagedFlux getEvents()
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()));
public BlobChangefeedPagedFlux getEvents(OffsetDateTime startTime, OffsetDateTime endTime)
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()));
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.public BlobChangefeedPagedFlux getEvents(String cursor)
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()));
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.Copyright © 2021 Microsoft Corporation. All rights reserved.