Package com.azure.storage.blob.changefeed

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:

  • Method Details

    • 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.