public final class ZooKeeperUtils extends Object
ZooKeeperUtils
contains static utility functions mostly for
retrieving optional message properties from Message headers.Modifier and Type | Method and Description |
---|---|
static List<org.apache.zookeeper.data.ACL> |
getAclListFromMessage(org.apache.camel.Message in) |
static org.apache.zookeeper.CreateMode |
getCreateMode(org.apache.camel.Message message,
org.apache.zookeeper.CreateMode defaultMode)
Pulls a createMode flag from the header keyed by
ZooKeeperMessage.ZOOKEEPER_CREATE_MODE in the given message and
attempts to parse a CreateMode from it. |
static org.apache.zookeeper.CreateMode |
getCreateModeFromString(String modeHeader,
org.apache.zookeeper.CreateMode defaultMode) |
static String |
getNodeFromMessage(org.apache.camel.Message message,
String defaultNode)
Pulls the target node from the header keyed by
ZooKeeperMessage.ZOOKEEPER_NODE . |
static byte[] |
getPayloadFromExchange(org.apache.camel.Exchange exchange) |
static Integer |
getVersionFromMessage(org.apache.camel.Message message) |
static org.apache.zookeeper.WatchedEvent |
getWatchedEvent(ZooKeeperOperation<?> zooKeeperOperation) |
static <T> T |
getZookeeperProperty(org.apache.camel.Message m,
String propertyName,
T defaultValue,
Class<? extends T> type) |
static boolean |
hasWatchedEvent(ZooKeeperOperation<?> zooKeeperOperation) |
public static org.apache.zookeeper.CreateMode getCreateMode(org.apache.camel.Message message, org.apache.zookeeper.CreateMode defaultMode)
ZooKeeperMessage.ZOOKEEPER_CREATE_MODE
in the given message and
attempts to parse a CreateMode
from it.message
- the message that may contain a ZOOKEEPER_CREATE_MODE
header.CreateMode
or null if the header was null or
not a valid mode flag.public static org.apache.zookeeper.CreateMode getCreateModeFromString(String modeHeader, org.apache.zookeeper.CreateMode defaultMode)
public static String getNodeFromMessage(org.apache.camel.Message message, String defaultNode)
ZooKeeperMessage.ZOOKEEPER_NODE
. This node is then typically used
in place of the configured node extracted from the endpoint uri.message
- the message that may contain a ZOOKEEPER_NODE header.public static Integer getVersionFromMessage(org.apache.camel.Message message)
public static byte[] getPayloadFromExchange(org.apache.camel.Exchange exchange)
public static List<org.apache.zookeeper.data.ACL> getAclListFromMessage(org.apache.camel.Message in)
public static <T> T getZookeeperProperty(org.apache.camel.Message m, String propertyName, T defaultValue, Class<? extends T> type)
public static org.apache.zookeeper.WatchedEvent getWatchedEvent(ZooKeeperOperation<?> zooKeeperOperation)
public static boolean hasWatchedEvent(ZooKeeperOperation<?> zooKeeperOperation)
Apache Camel