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