org.apache.camel.component.zookeeper
Class ZooKeeperEndpoint

java.lang.Object
  org.apache.camel.support.ServiceSupport
      org.apache.camel.impl.DefaultEndpoint
          org.apache.camel.component.zookeeper.ZooKeeperEndpoint

All Implemented Interfaces:

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")
public class ZooKeeperEndpoint
extends org.apache.camel.impl.DefaultEndpoint

ZooKeeperEndpoint

Field Summary

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

shutdown, shuttingdown, started, starting, stopped, stopping, suspended, suspending

Constructor Summary

ZooKeeperEndpoint(String uri, ZooKeeperComponent component, ZooKeeperConfiguration configuration)

Method Summary

void	addServer(String server)
void	clearServers()
org.apache.camel.Consumer	createConsumer(org.apache.camel.Processor processor)
org.apache.camel.Producer	createProducer()
protected void	doStop()
boolean	getAwaitExistence() Deprecated. The usage of this property has no effect at all.
long	getBackoff()
String	getCamelId()
String	getCamelManagementName()
ZooKeeperConfiguration	getConfiguration()
boolean	getCreate()
String	getEndpointUri()
Object	getManagedObject(ZooKeeperEndpoint arg0)
String	getPath()
boolean	getRepeat()
List<String>	getServers()
String	getState()
int	getTimeout()
boolean	isListChildren()
boolean	isSendEmptyMessageOnDelete()
boolean	isSingleton()
void	setAwaitExistence(boolean awaitExistence) Deprecated. The usage of this property has no effect at all.
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.impl.DefaultEndpoint

configureConsumer, configurePollingConsumer, configureProperties, createEndpointConfiguration, createEndpointUri, createExchange, createExchange, createExchange, createPollingConsumer, doStart, equals, getCamelContext, getComponent, getConsumerProperties, getEndpointConfiguration, getEndpointKey, getExchangePattern, getId, hashCode, isLenientProperties, isSynchronous, setCamelContext, setConsumerProperties, setEndpointConfiguration, setEndpointUri, setEndpointUriIfNotSpecified, setExchangePattern, setProperties, setSynchronous, toString

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

doResume, doShutdown, doSuspend, getStatus, getVersion, isRunAllowed, isStarted, isStarting, isStopped, isStopping, isStoppingOrStopped, isSuspended, isSuspending, 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.Service

start, stop

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

isSingleton

public boolean isSingleton()

setConfiguration

public void setConfiguration(ZooKeeperConfiguration configuration)

getConfiguration

public ZooKeeperConfiguration getConfiguration()

getCamelId

@ManagedAttribute(description="Camel ID")
public String getCamelId()

getCamelManagementName

@ManagedAttribute(description="Camel ManagementName")
public String getCamelManagementName()

getEndpointUri

@ManagedAttribute(description="Endpoint Uri",
                  mask=true)
public String getEndpointUri()

Specified by:

getEndpointUri in interface org.apache.camel.Endpoint

Overrides:

getEndpointUri in class org.apache.camel.impl.DefaultEndpoint

getState

@ManagedAttribute(description="Service State")
public String getState()

setPath

@ManagedAttribute
public void setPath(String path)

getPath

@ManagedAttribute
public String getPath()

getTimeout

@ManagedAttribute
public int getTimeout()

setTimeout

@ManagedAttribute
public void setTimeout(int timeout)

getRepeat

@ManagedAttribute
public boolean getRepeat()

setRepeat

@ManagedAttribute
public void setRepeat(boolean shouldRepeat)

getServers

@ManagedAttribute
public List<String> getServers()

setServers

@ManagedAttribute
public void setServers(List<String> servers)

isListChildren

@ManagedAttribute
public boolean isListChildren()

setListChildren

@ManagedAttribute
public void setListChildren(boolean listChildren)

getCreate

@ManagedAttribute
public boolean getCreate()

setCreate

@ManagedAttribute
public void setCreate(boolean shouldCreate)

getBackoff

@ManagedAttribute
public long getBackoff()

setBackoff

@ManagedAttribute
public void setBackoff(long backoff)

getAwaitExistence

@Deprecated
@ManagedAttribute
public boolean getAwaitExistence()

Deprecated. The usage of this property has no effect at all.

setAwaitExistence

@Deprecated
@ManagedAttribute
public void setAwaitExistence(boolean awaitExistence)

Deprecated. The usage of this property has no effect at all.

addServer

@ManagedOperation
public void addServer(String server)

clearServers

@ManagedOperation
public void clearServers()

getManagedObject

public Object getManagedObject(ZooKeeperEndpoint arg0)

isSendEmptyMessageOnDelete

@ManagedAttribute
public boolean isSendEmptyMessageOnDelete()

setSendEmptyMessageOnDelete

@ManagedAttribute
public void setSendEmptyMessageOnDelete(boolean sendEmptyMessageOnDelete)

doStop

protected void doStop()
               throws Exception

Overrides:

doStop in class org.apache.camel.impl.DefaultEndpoint

Throws:

Exception