Package org.apache.camel.component.zookeeper

Class ZooKeeperMessage

java.lang.Object
org.apache.camel.support.MessageSupport
org.apache.camel.support.DefaultMessage
org.apache.camel.component.zookeeper.ZooKeeperMessage
All Implemented Interfaces:
org.apache.camel.CamelContextAware, org.apache.camel.Message, org.apache.camel.spi.DataTypeAware, org.apache.camel.spi.HasCamelContext
public class ZooKeeperMessage extends org.apache.camel.support.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

    Fields
    Modifier and Type
    Field
    Description
    static final String
    ZOOKEEPER_ACL
     
    static final String
    ZOOKEEPER_CREATE_MODE
     
    static final String
    ZOOKEEPER_ERROR_CODE
     
    static final String
    ZOOKEEPER_EVENT_TYPE
     
    static final String
    ZOOKEEPER_NODE
     
    static final String
    ZOOKEEPER_NODE_VERSION
     
    static final String
    ZOOKEEPER_OPERATION
     
    static final String
    ZOOKEEPER_STATISTICS
     

    Fields inherited from class org.apache.camel.support.MessageSupport

    camelContext, typeConverter

  • Constructor Summary

    Constructors
    Constructor
    Description
    ZooKeeperMessage(org.apache.camel.CamelContext camelContext)
     
    ZooKeeperMessage(org.apache.camel.CamelContext camelContext, String node, org.apache.zookeeper.data.Stat statistics, Map<String,Object> headers)
     
    ZooKeeperMessage(org.apache.camel.CamelContext camelContext, String node, org.apache.zookeeper.data.Stat statistics, Map<String,Object> headers, org.apache.zookeeper.WatchedEvent watchedEvent)
     
    ZooKeeperMessage(org.apache.camel.CamelContext camelContext, String node, org.apache.zookeeper.data.Stat statistics, org.apache.zookeeper.WatchedEvent watchedEvent)
     

  • Method Summary

    Modifier and Type
    Method
    Description
    static String
    getPath(org.apache.camel.Message message)
     
    static org.apache.zookeeper.data.Stat
    getStatistics(org.apache.camel.Message message)
     
    org.apache.camel.support.DefaultMessage
    newInstance()
     

    Methods inherited from class org.apache.camel.support.DefaultMessage

    createHeaders, getHeader, getHeader, getHeader, getHeader, getHeader, getHeader, getHeaders, hasHeaders, hasPopulatedHeaders, populateInitialHeaders, removeHeader, removeHeaders, removeHeaders, reset, setHeader, setHeaders

    Methods inherited from class org.apache.camel.support.MessageSupport

    copy, copyFrom, copyFromWithNewBody, createBody, createMessageId, getBody, getBody, getBody, getCamelContext, getDataType, getExchange, getMandatoryBody, getMandatoryBody, getMessageId, getMessageTimestamp, getPayloadForTrait, hasDataType, hasMessageId, hasTrait, setBody, setBody, setBody, setCamelContext, setDataType, setExchange, setMessageId, setPayloadForTrait, toString

    Methods inherited from class java.lang.Object

    clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

  • Field Details

    • ZOOKEEPER_NODE

      @Metadata(description="The node", javaType="String") public static final String ZOOKEEPER_NODE
      See Also:

    • ZOOKEEPER_NODE_VERSION

      @Metadata(description="The node version", javaType="Integer", defaultValue="-1") public static final String ZOOKEEPER_NODE_VERSION
      See Also:

    • ZOOKEEPER_ERROR_CODE

      public static final String ZOOKEEPER_ERROR_CODE
      See Also:

    • ZOOKEEPER_ACL

      @Metadata(description="The ACL", javaType="List<ACL>", defaultValue="Ids.OPEN_ACL_UNSAFE") public static final String ZOOKEEPER_ACL
      See Also:

    • ZOOKEEPER_CREATE_MODE

      @Metadata(description="The create mode", javaType="org.apache.zookeeper.CreateMode or String") public static final String ZOOKEEPER_CREATE_MODE
      See Also:

    • ZOOKEEPER_STATISTICS

      @Metadata(description="The statistics", javaType="org.apache.zookeeper.data.Stat") public static final String ZOOKEEPER_STATISTICS
      See Also:

    • ZOOKEEPER_EVENT_TYPE

      @Metadata(description="The event type", javaType="org.apache.zookeeper.Watcher.Event.EventType") public static final String ZOOKEEPER_EVENT_TYPE
      See Also:

    • ZOOKEEPER_OPERATION

      @Metadata(label="producer", description="The operation to perform", javaType="String") public static final String ZOOKEEPER_OPERATION
      See Also:

  • Constructor Details

    • ZooKeeperMessage

      public ZooKeeperMessage(org.apache.camel.CamelContext camelContext)

    • ZooKeeperMessage

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

    • ZooKeeperMessage

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

    • ZooKeeperMessage

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

  • Method Details

    • getStatistics

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

    • getPath

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

    • newInstance

      public org.apache.camel.support.DefaultMessage newInstance()
      Overrides:
      newInstance in class org.apache.camel.support.DefaultMessage