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