Package com.eventstore.dbclient

Class PersistentSubscription

  • public class PersistentSubscription
extends java.lang.Object
    Persistent subscription handle.

    • Method Summary

      All Methods Instance Methods Concrete Methods 
      Modifier and Type Method Description
      void ack​(ResolvedEvent... events)
      Acknowledges events have been successfully processed.
      void ack​(java.util.Iterator<ResolvedEvent> events)
      Acknowledges events have been successfully processed.
      java.lang.String getSubscriptionId()
      Returns the persistent subscription's id.
      void nack​(NackAction action, java.lang.String reason, ResolvedEvent... events)
      Acknowledges events failed processing.
      void nack​(NackAction action, java.lang.String reason, java.util.Iterator<ResolvedEvent> events)
      Acknowledges events failed processing.
      void stop()
      Stops the persistent subscription.

      • Methods inherited from class java.lang.Object

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

    • Method Detail

      • getSubscriptionId

        public java.lang.String getSubscriptionId()
        Returns the persistent subscription's id.

      • stop

        public void stop()
        Stops the persistent subscription.

      • ack

        public void ack​(ResolvedEvent... events)
        Acknowledges events have been successfully processed.

      • ack

        public void ack​(java.util.Iterator<ResolvedEvent> events)
        Acknowledges events have been successfully processed.

      • nack

        public void nack​(NackAction action,
                 java.lang.String reason,
                 ResolvedEvent... events)
        Acknowledges events failed processing.

      • nack

        public void nack​(NackAction action,
                 java.lang.String reason,
                 java.util.Iterator<ResolvedEvent> events)
        Acknowledges events failed processing.