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:

CamelContextAware, Endpoint, IsSingleton, Service, ShutdownableService, HasId, StatefulService, SuspendableService

@ManagedResource(description="ZooKeeper Endpoint")
@UriEndpoint(scheme="zookeeper",
             title="ZooKeeper",
             syntax="zookeeper:serverUrls/path",
             consumerClass=ZooKeeperConsumer.class,
             label="clustering")
public class ZooKeeperEndpoint
extends DefaultEndpoint

ZooKeeperEndpoint

Field Summary

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

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

Constructor Summary

Constructors

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

Method Summary

Methods

Modifier and Type	Method and Description
void	addServer(String server)
void	clearServers()
Consumer	createConsumer(Processor processor) Creates a new Event Driven Consumer which consumes messages from the endpoint using the given processor
Producer	createProducer() Creates a new producer which is used send messages into the endpoint
protected void	doStop() Implementations override this method to support customized start/stop.
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() Returns the string representation of the endpoint URI
Object	getManagedObject(ZooKeeperEndpoint arg0)
String	getPath()
boolean	getRepeat()
List<String>	getServers()
String	getState()
int	getTimeout()
boolean	isListChildren()
boolean	isSendEmptyMessageOnDelete()
boolean	isSingleton() Whether this class supports being singleton or not.
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, getPollingConsumerQueueSize, hashCode, isLenientProperties, isPollingConsumerBlockWhenFull, isSynchronous, setCamelContext, setConsumerProperties, setEndpointConfiguration, setEndpointUri, setEndpointUriIfNotSpecified, setExchangePattern, setPollingConsumerBlockWhenFull, setPollingConsumerQueueSize, 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 Producer createProducer()
                        throws Exception

Description copied from interface: Endpoint

Creates a new producer which is used send messages into the endpoint

Returns:

a newly created producer

Throws:

Exception - can be thrown

createConsumer

public Consumer createConsumer(Processor processor)
                        throws Exception

Description copied from interface: Endpoint

Creates a new Event Driven Consumer which consumes messages from the endpoint using the given processor

Parameters:

processor - the given processor

Returns:

a newly created consumer

Throws:

Exception - can be thrown

isSingleton

public boolean isSingleton()

Description copied from interface: IsSingleton

Whether this class supports being singleton or not.

Returns:

true to be a single shared instance, false to create new instances.

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()

Description copied from interface: Endpoint

Returns the string representation of the endpoint URI

Specified by:

getEndpointUri in interface Endpoint

Overrides:

getEndpointUri in class DefaultEndpoint

Returns:

the endpoint URI

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

Description copied from class: ServiceSupport

Implementations override this method to support customized start/stop.

Important: Camel will invoke this ServiceSupport.doStop() method when the service is being stopped. This method will also be invoked if the service is still in uninitialized state (eg has not been started). The method is always called to allow the service to do custom logic when the service is being stopped, such as when CamelContext is shutting down.

Overrides:

doStop in class DefaultEndpoint

Throws:

Exception

See Also:

ServiceSupport.doStart()