public class StreamEndMessage extends AbstractDCPRequest
Modifier and Type | Class and Description |
---|---|
static class |
StreamEndMessage.Reason |
DEFAULT_PARTITION
Constructor and Description |
---|
StreamEndMessage(StreamEndMessage.Reason reason,
String bucket) |
Modifier and Type | Method and Description |
---|---|
StreamEndMessage.Reason |
reason()
Specify to the consumer why the stream was closed
|
partition, partition, toString
bucket, creationTime, incrementRetryCount, observable, password
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
bucket, incrementRetryCount, observable, password
creationTime
public StreamEndMessage(StreamEndMessage.Reason reason, String bucket)
public StreamEndMessage.Reason reason()
Specify to the consumer why the stream was closed
Copyright © 2016 Couchbase, Inc.. All rights reserved.