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