Package com.eventstore.dbclient

Class PersistentSubscriptionListener

java.lang.Object

com.eventstore.dbclient.PersistentSubscriptionListener

public abstract class PersistentSubscriptionListener
extends Object

Listener used to handle persistent subscription notifications raised throughout its lifecycle.

Constructor Summary

Constructors

Constructor	Description
PersistentSubscriptionListener()

Method Summary

Modifier and Type	Method	Description
void	onCancelled(PersistentSubscription subscription, Throwable exception)	Called when the subscription is cancelled or dropped.
void	onConfirmation(PersistentSubscription subscription)	Called when the subscription is confirmed by the server.
void	onEvent(PersistentSubscription subscription, int retryCount, ResolvedEvent event)	Called when EventStoreDB sends an event to the persistent subscription.

Methods inherited from class java.lang.Object

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

Constructor Details

PersistentSubscriptionListener

public PersistentSubscriptionListener()

Method Details

onEvent

public void onEvent(PersistentSubscription subscription,
 int retryCount,
 ResolvedEvent event)

Called when EventStoreDB sends an event to the persistent subscription.

Parameters:

subscription - handle to the persistent subscription.

retryCount - how many times the event was retried.

event - a resolved event.

onCancelled

public void onCancelled(PersistentSubscription subscription,
 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(PersistentSubscription subscription)

Called when the subscription is confirmed by the server.

Parameters:

subscription - handle to the subscription.