Package com.eventstore.dbclient

Class PersistentSubscription

java.lang.Object

com.eventstore.dbclient.PersistentSubscription

public class PersistentSubscription
extends Object

Persistent subscription handle.

Method Summary

Modifier and Type	Method	Description
void	ack(ResolvedEvent... events)	Acknowledges events have been successfully processed.
void	ack(Iterator<ResolvedEvent> events)	Acknowledges events have been successfully processed.
String	getSubscriptionId()	Returns the persistent subscription's id.
void	nack(NackAction action, String reason, ResolvedEvent... events)	Acknowledges events failed processing.
void	nack(NackAction action, String reason, 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 Details

getSubscriptionId

public 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(Iterator<ResolvedEvent> events)

Acknowledges events have been successfully processed.

nack

public void nack(NackAction action,
 String reason,
 ResolvedEvent... events)

Acknowledges events failed processing.

nack

public void nack(NackAction action,
 String reason,
 Iterator<ResolvedEvent> events)

Acknowledges events failed processing.