public class DCPEvent extends Object
CouchbaseMessage
and associated information.Constructor and Description |
---|
DCPEvent() |
Modifier and Type | Method and Description |
---|---|
com.couchbase.client.core.endpoint.dcp.DCPConnection |
connection()
Get the associated DCP connection object.
|
String |
key()
Extract key from the payload.
|
com.couchbase.client.core.message.CouchbaseMessage |
message()
Get the message from the payload.
|
void |
setConnection(com.couchbase.client.core.endpoint.dcp.DCPConnection connection) |
DCPEvent |
setMessage(com.couchbase.client.core.message.CouchbaseMessage message)
Set the new message as a payload for this event.
|
public DCPEvent setMessage(com.couchbase.client.core.message.CouchbaseMessage message)
message
- the message to override.DCPEvent
for method chaining.public com.couchbase.client.core.message.CouchbaseMessage message()
public void setConnection(com.couchbase.client.core.endpoint.dcp.DCPConnection connection)
public com.couchbase.client.core.endpoint.dcp.DCPConnection connection()
public String key()
Copyright © 2015 Couchbase, Inc.