Package org.apache.camel.component.zookeeper

Class ZooKeeperEndpoint

java.lang.Object
org.apache.camel.support.service.BaseService
org.apache.camel.support.service.ServiceSupport
org.apache.camel.support.DefaultEndpoint
org.apache.camel.component.zookeeper.ZooKeeperEndpoint
All Implemented Interfaces:
AutoCloseable, org.apache.camel.CamelContextAware, org.apache.camel.ComponentAware, org.apache.camel.Endpoint, org.apache.camel.IsSingleton, org.apache.camel.Service, org.apache.camel.ShutdownableService, org.apache.camel.spi.EndpointServiceLocation, org.apache.camel.spi.HasCamelContext, org.apache.camel.spi.HasId, org.apache.camel.StatefulService, org.apache.camel.SuspendableService
@ManagedResource(description="ZooKeeper Endpoint") @UriEndpoint(firstVersion="2.9.0", scheme="zookeeper", title="ZooKeeper", syntax="zookeeper:serverUrls/path", category={CLUSTERING,MANAGEMENT,BIGDATA}, headersClass=ZooKeeperMessage.class) public class ZooKeeperEndpoint extends org.apache.camel.support.DefaultEndpoint implements org.apache.camel.spi.EndpointServiceLocation
Manage ZooKeeper clusters.

  • Field Summary

    Fields inherited from class org.apache.camel.support.service.BaseService

    BUILT, FAILED, INITIALIZED, INITIALIZING, lock, NEW, SHUTDOWN, SHUTTING_DOWN, STARTED, STARTING, status, STOPPED, STOPPING, SUSPENDED, SUSPENDING

  • Constructor Summary

    Constructors
    Constructor
    Description
    ZooKeeperEndpoint(String uri, ZooKeeperComponent component, ZooKeeperConfiguration configuration)
     

  • Method Summary

    Modifier and Type
    Method
    Description
    void
    addServer(String server)
     
    void
    clearServers()
     
    org.apache.camel.Consumer
    createConsumer(org.apache.camel.Processor processor)
     
    org.apache.camel.Producer
    createProducer()
     
    protected void
    doStop()
     
    long
    getBackoff()
     
    ZooKeeperConfiguration
    getConfiguration()
     
    boolean
    getCreate()
     
    String
    getPath()
     
    boolean
    getRepeat()
     
    List<String>
    getServers()
     
    String
    getServiceProtocol()
     
    String
    getServiceUrl()
     
    int
    getTimeout()
     
    boolean
    isListChildren()
     
    boolean
    isSendEmptyMessageOnDelete()
     
    void
    setBackoff(long backoff)
     
    void
    setConfiguration(ZooKeeperConfiguration configuration)
     
    void
    setCreate(boolean shouldCreate)
     
    void
    setListChildren(boolean listChildren)
     
    void
    setPath(String path)
     
    void
    setRepeat(boolean shouldRepeat)
     
    void
    setSendEmptyMessageOnDelete(boolean sendEmptyMessageOnDelete)
     
    void
    setServers(List<String> servers)
     
    void
    setTimeout(int timeout)
     

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

    configureConsumer, configureExchange, configurePollingConsumer, configureProperties, createAsyncProducer, createEndpointUri, createExchange, createExchange, createPollingConsumer, doInit, equals, getCamelContext, getComponent, getEndpointKey, getEndpointUri, getExceptionHandler, getExchangePattern, getId, getPollingConsumerBlockTimeout, getPollingConsumerQueueSize, hashCode, isAutowiredEnabled, isBridgeErrorHandler, isLazyStartProducer, isLenientProperties, isPollingConsumerBlockWhenFull, isPollingConsumerCopy, isSingleton, setAutowiredEnabled, setBridgeErrorHandler, setCamelContext, setComponent, setEndpointUri, setEndpointUriIfNotSpecified, setExceptionHandler, setExchangePattern, setLazyStartProducer, setPollingConsumerBlockTimeout, setPollingConsumerBlockWhenFull, setPollingConsumerCopy, setPollingConsumerQueueSize, setProperties, toString

    Methods inherited from class org.apache.camel.support.service.BaseService

    build, doBuild, doFail, doLifecycleChange, doResume, doShutdown, doStart, doSuspend, fail, getInternalLock, getStatus, init, isBuild, isInit, isNew, isRunAllowed, isShutdown, isStarted, isStarting, isStartingOrStarted, isStopped, isStopping, isStoppingOrStopped, isSuspended, isSuspending, isSuspendingOrSuspended, resume, shutdown, start, stop, suspend

    Methods inherited from class java.lang.Object

    clone, finalize, getClass, notify, notifyAll, wait, wait, wait

    Methods inherited from interface org.apache.camel.ComponentAware

    getComponent

    Methods inherited from interface org.apache.camel.Endpoint

    getEndpointBaseUri, isRemote, isSingletonProducer

    Methods inherited from interface org.apache.camel.spi.EndpointServiceLocation

    getServiceMetadata

    Methods inherited from interface org.apache.camel.Service

    build, close, init, start, stop

    Methods inherited from interface org.apache.camel.ShutdownableService

    shutdown

    Methods inherited from interface org.apache.camel.StatefulService

    getStatus, isRunAllowed, isStarted, isStarting, isStopped, isStopping, isSuspending

    Methods inherited from interface org.apache.camel.SuspendableService

    isSuspended, resume, suspend

  • Constructor Details

  • Method Details

    • getServiceUrl

      public String getServiceUrl()
      Specified by:
      getServiceUrl in interface org.apache.camel.spi.EndpointServiceLocation

    • getServiceProtocol

      public String getServiceProtocol()
      Specified by:
      getServiceProtocol in interface org.apache.camel.spi.EndpointServiceLocation

    • createProducer

      public org.apache.camel.Producer createProducer() throws Exception
      Specified by:
      createProducer in interface org.apache.camel.Endpoint
      Throws:
      Exception

    • createConsumer

      public org.apache.camel.Consumer createConsumer(org.apache.camel.Processor processor) throws Exception
      Specified by:
      createConsumer in interface org.apache.camel.Endpoint
      Throws:
      Exception

    • setConfiguration

      public void setConfiguration(ZooKeeperConfiguration configuration)

    • getConfiguration

      public ZooKeeperConfiguration getConfiguration()

    • setPath

      public void setPath(String path)

    • getPath

      @ManagedAttribute public String getPath()

    • getTimeout

      @ManagedAttribute public int getTimeout()

    • setTimeout

      public void setTimeout(int timeout)

    • getRepeat

      @ManagedAttribute public boolean getRepeat()

    • setRepeat

      public void setRepeat(boolean shouldRepeat)

    • getServers

      @ManagedAttribute public List<String> getServers()

    • setServers

      public void setServers(List<String> servers)

    • isListChildren

      @ManagedAttribute public boolean isListChildren()

    • setListChildren

      public void setListChildren(boolean listChildren)

    • getCreate

      @ManagedAttribute public boolean getCreate()

    • setCreate

      public void setCreate(boolean shouldCreate)

    • getBackoff

      @ManagedAttribute public long getBackoff()

    • setBackoff

      public void setBackoff(long backoff)

    • addServer

      @ManagedOperation public void addServer(String server)

    • clearServers

      @ManagedOperation public void clearServers()

    • isSendEmptyMessageOnDelete

      @ManagedAttribute public boolean isSendEmptyMessageOnDelete()

    • setSendEmptyMessageOnDelete

      public void setSendEmptyMessageOnDelete(boolean sendEmptyMessageOnDelete)

    • doStop

      protected void doStop() throws Exception
      Overrides:
      doStop in class org.apache.camel.support.service.BaseService
      Throws:
      Exception