org.apache.camel.component.zookeeper
Class ZooKeeperMessage

java.lang.Object
  extended by org.apache.camel.impl.MessageSupport
      extended by org.apache.camel.impl.DefaultMessage
          extended by org.apache.camel.component.zookeeper.ZooKeeperMessage
All Implemented Interfaces:
org.apache.camel.Message

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.


Field Summary
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_STATISTICS
           
 
Constructor Summary
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)
           
 
Method Summary
static String getPath(org.apache.camel.Message message)
           
static org.apache.zookeeper.data.Stat getStatistics(org.apache.camel.Message message)
           
 
Methods inherited from class org.apache.camel.impl.DefaultMessage
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, toString
 
Methods inherited from class org.apache.camel.impl.MessageSupport
copy, copyFrom, createBody, createMessageId, getBody, getBody, getBody, getExchange, getMandatoryBody, getMandatoryBody, getMessageId, setBody, setBody, setExchange, setMessageId
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
 

Field Detail

ZOOKEEPER_NODE

public static final String ZOOKEEPER_NODE
See Also:
Constant Field Values

ZOOKEEPER_NODE_VERSION

public static final String ZOOKEEPER_NODE_VERSION
See Also:
Constant Field Values

ZOOKEEPER_ERROR_CODE

public static final String ZOOKEEPER_ERROR_CODE
See Also:
Constant Field Values

ZOOKEEPER_ACL

public static final String ZOOKEEPER_ACL
See Also:
Constant Field Values

ZOOKEEPER_CREATE_MODE

public static final String ZOOKEEPER_CREATE_MODE
See Also:
Constant Field Values

ZOOKEEPER_STATISTICS

public static final String ZOOKEEPER_STATISTICS
See Also:
Constant Field Values

ZOOKEEPER_EVENT_TYPE

public static final String ZOOKEEPER_EVENT_TYPE
See Also:
Constant Field Values
Constructor Detail

ZooKeeperMessage

public ZooKeeperMessage(String node,
                        org.apache.zookeeper.data.Stat statistics,
                        org.apache.zookeeper.WatchedEvent watchedEvent)

ZooKeeperMessage

public ZooKeeperMessage(String node,
                        org.apache.zookeeper.data.Stat statistics,
                        Map<String,Object> headers)

ZooKeeperMessage

public ZooKeeperMessage(String node,
                        org.apache.zookeeper.data.Stat statistics,
                        Map<String,Object> headers,
                        org.apache.zookeeper.WatchedEvent watchedEvent)
Method Detail

getStatistics

public static org.apache.zookeeper.data.Stat getStatistics(org.apache.camel.Message message)

getPath

public static String getPath(org.apache.camel.Message message)


Apache CAMEL