Package com.eventstore.dbclient

Class SubscriptionListener

  • public abstract class SubscriptionListener
extends java.lang.Object
    Listener used to handle catch-up subscription notifications raised throughout its lifecycle.

    • Method Summary

      All Methods Instance Methods Concrete Methods 
      Modifier and Type Method Description
      void onCancelled​(Subscription subscription, java.lang.Throwable exception)
      Called when the subscription is cancelled or dropped.
      void onCaughtUp​(Subscription subscription)
      Called when the subscription has reached the head of the stream.
      void onConfirmation​(Subscription subscription)
      Called when the subscription is confirmed by the server.
      void onEvent​(Subscription subscription, ResolvedEvent event)
      Called when EventStoreDB sends an event to the subscription.
      void onFellBehind​(Subscription subscription)
      Called when the subscription has fallen behind, meaning it's no longer keeping up with the stream's pace.

      • Methods inherited from class java.lang.Object

        clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

    • Constructor Detail

      • SubscriptionListener

        public SubscriptionListener()

    • Method Detail

      • onEvent

        public void onEvent​(Subscription subscription,
                    ResolvedEvent event)
        Called when EventStoreDB sends an event to the subscription.
        Parameters:
        subscription - handle to the subscription.
        event - a resolved event.

      • onCancelled

        public void onCancelled​(Subscription subscription,
                        java.lang.Throwable exception)
        Called when the subscription is cancelled or dropped.
        Parameters:
        subscription - handle to the subscription.
        exception - an exception. null if the user initiated the cancellation.

      • onConfirmation

        public void onConfirmation​(Subscription subscription)
        Called when the subscription is confirmed by the server.
        Parameters:
        subscription - handle to the subscription.

      • onCaughtUp

        public void onCaughtUp​(Subscription subscription)
        Called when the subscription has reached the head of the stream.
        Parameters:
        subscription - handle to the subscription.

      • onFellBehind

        public void onFellBehind​(Subscription subscription)
        Called when the subscription has fallen behind, meaning it's no longer keeping up with the stream's pace.
        Parameters:
        subscription - handle to the subscription.