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.Endpoint, org.apache.camel.IsSingleton, org.apache.camel.Service, org.apache.camel.ShutdownableService, 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})
public class ZooKeeperEndpoint
extends org.apache.camel.support.DefaultEndpoint

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 and Description
ZooKeeperEndpoint(String uri, ZooKeeperComponent component, ZooKeeperConfiguration configuration)

Method Summary

Modifier and Type	Method and 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()
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, configurePollingConsumer, configureProperties, createAsyncProducer, createEndpointUri, createExchange, createExchange, createPollingConsumer, doInit, doStart, equals, getCamelContext, getComponent, getEndpointKey, getEndpointUri, getExceptionHandler, getExchangePattern, getId, getPollingConsumerBlockTimeout, getPollingConsumerQueueSize, hashCode, isAutowiredEnabled, isBridgeErrorHandler, isLazyStartProducer, isLenientProperties, isPollingConsumerBlockWhenFull, isSingleton, isSynchronous, setAutowiredEnabled, setBridgeErrorHandler, setCamelContext, setComponent, setEndpointUri, setEndpointUriIfNotSpecified, setExceptionHandler, setExchangePattern, setLazyStartProducer, setPollingConsumerBlockTimeout, setPollingConsumerBlockWhenFull, setPollingConsumerQueueSize, setProperties, setSynchronous, toString

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

build, doBuild, doFail, doLifecycleChange, doResume, doShutdown, doSuspend, fail, 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.Endpoint

getEndpointBaseUri, isSingletonProducer

Methods inherited from interface org.apache.camel.IsSingleton

test

Methods inherited from interface org.apache.camel.Service

build, close, init, start, stop

Methods inherited from interface org.apache.camel.CamelContextAware

trySetCamelContext

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

Methods inherited from interface org.apache.camel.ShutdownableService

shutdown

Constructor Detail

ZooKeeperEndpoint

public ZooKeeperEndpoint(String uri,
                         ZooKeeperComponent component,
                         ZooKeeperConfiguration configuration)

Method Detail

createProducer

public org.apache.camel.Producer createProducer()
                                         throws Exception

Throws:

Exception

createConsumer

public org.apache.camel.Consumer createConsumer(org.apache.camel.Processor processor)
                                         throws Exception

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.DefaultEndpoint

Throws:

Exception