com.eventstore.dbclient

Class PersistentSubscription

java.lang.Object

com.eventstore.dbclient.PersistentSubscription

public class PersistentSubscription
extends java.lang.Object

Constructor Summary

Constructors

Constructor and Description
PersistentSubscription(io.grpc.stub.ClientCallStreamObserver<com.eventstore.dbclient.proto.persistentsubscriptions.Persistent.ReadReq> requestStream, java.lang.String subscriptionId, java.lang.String streamName, java.lang.String groupName, int bufferSize, com.eventstore.dbclient.proto.persistentsubscriptions.Persistent.ReadReq.Options.Builder options)

Method Summary

Modifier and Type	Method and Description
void	ack(java.util.Iterator<ResolvedEvent> events)
void	ack(ResolvedEvent... events)
java.lang.String	getSubscriptionId()
void	nack(NackAction action, java.lang.String reason, java.util.Iterator<ResolvedEvent> events)
void	nack(NackAction action, java.lang.String reason, ResolvedEvent... events)
void	stop()

Methods inherited from class java.lang.Object

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

Constructor Detail

PersistentSubscription

public PersistentSubscription(io.grpc.stub.ClientCallStreamObserver<com.eventstore.dbclient.proto.persistentsubscriptions.Persistent.ReadReq> requestStream,
                              java.lang.String subscriptionId,
                              java.lang.String streamName,
                              java.lang.String groupName,
                              int bufferSize,
                              com.eventstore.dbclient.proto.persistentsubscriptions.Persistent.ReadReq.Options.Builder options)

Method Detail

getSubscriptionId

public java.lang.String getSubscriptionId()

stop

public void stop()

ack

public void ack(ResolvedEvent... events)

ack

public void ack(java.util.Iterator<ResolvedEvent> events)

nack

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

nack

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