public class ZooKeeperMessage
extends org.apache.camel.impl.DefaultMessage
ZooKeeperMessage
is a Message
representing interactions with a ZooKeeper service. It contains a number of
optional Header Constants that are used by the Producer and consumer
mechanisms to finely control these interactions.Modifier and Type | Field and Description |
---|---|
static String |
ZOOKEEPER_ACL |
static String |
ZOOKEEPER_CREATE_MODE |
static String |
ZOOKEEPER_ERROR_CODE |
static String |
ZOOKEEPER_EVENT_TYPE |
static String |
ZOOKEEPER_NODE |
static String |
ZOOKEEPER_NODE_VERSION |
static String |
ZOOKEEPER_OPERATION |
static String |
ZOOKEEPER_STATISTICS |
Constructor and Description |
---|
ZooKeeperMessage(String node,
org.apache.zookeeper.data.Stat statistics,
Map<String,Object> headers) |
ZooKeeperMessage(String node,
org.apache.zookeeper.data.Stat statistics,
Map<String,Object> headers,
org.apache.zookeeper.WatchedEvent watchedEvent) |
ZooKeeperMessage(String node,
org.apache.zookeeper.data.Stat statistics,
org.apache.zookeeper.WatchedEvent watchedEvent) |
Modifier and Type | Method and Description |
---|---|
static String |
getPath(org.apache.camel.Message message) |
static org.apache.zookeeper.data.Stat |
getStatistics(org.apache.camel.Message message) |
addAttachment, createAttachments, createExchangeId, createHeaders, getAttachment, getAttachmentNames, getAttachments, getHeader, getHeader, getHeader, getHeader, getHeaders, hasAttachments, hasHeaders, hasPopulatedHeaders, isFault, isTransactedRedelivered, newInstance, populateInitialAttachments, populateInitialHeaders, removeAttachment, removeHeader, removeHeaders, removeHeaders, setAttachments, setFault, setHeader, setHeaders
public static final String ZOOKEEPER_NODE
public static final String ZOOKEEPER_NODE_VERSION
public static final String ZOOKEEPER_ERROR_CODE
public static final String ZOOKEEPER_ACL
public static final String ZOOKEEPER_CREATE_MODE
public static final String ZOOKEEPER_STATISTICS
public static final String ZOOKEEPER_EVENT_TYPE
public static final String ZOOKEEPER_OPERATION
public ZooKeeperMessage(String node, org.apache.zookeeper.data.Stat statistics, org.apache.zookeeper.WatchedEvent watchedEvent)
public ZooKeeperMessage(String node, org.apache.zookeeper.data.Stat statistics, Map<String,Object> headers)
public static org.apache.zookeeper.data.Stat getStatistics(org.apache.camel.Message message)
public static String getPath(org.apache.camel.Message message)
Apache Camel