public class PersistentSubscription
extends java.lang.Object
| 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) |
| 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() |
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)
public java.lang.String getSubscriptionId()
public void stop()
public void ack(ResolvedEvent... events)
public void ack(java.util.Iterator<ResolvedEvent> events)
public void nack(NackAction action, java.lang.String reason, ResolvedEvent... events)
public void nack(NackAction action, java.lang.String reason, java.util.Iterator<ResolvedEvent> events)