org.apache.camel.component.routebox.seda
Class RouteboxSedaEndpoint

java.lang.Object
  org.apache.camel.impl.ServiceSupport
      org.apache.camel.impl.DefaultEndpoint
          org.apache.camel.component.routebox.RouteboxEndpoint
              org.apache.camel.component.routebox.seda.RouteboxSedaEndpoint

All Implemented Interfaces:

CamelContextAware, Endpoint, IsSingleton, MultipleConsumersSupport, Service, ShutdownableService, BrowsableEndpoint, HasId

public class RouteboxSedaEndpoint
extends RouteboxEndpoint
implements BrowsableEndpoint, MultipleConsumersSupport

Constructor Summary

RouteboxSedaEndpoint(String endpointUri, RouteboxComponent component, RouteboxConfiguration config)

RouteboxSedaEndpoint(String endpointUri, RouteboxComponent component, RouteboxConfiguration config, BlockingQueue<Exchange> queue)

Method Summary

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
Set<RouteboxConsumer>	getConsumers()
List<Exchange>	getExchanges() Return the exchanges available on this endpoint
Set<RouteboxProducer>	getProducers()
BlockingQueue<Exchange>	getQueue()
WaitForTaskToComplete	getWaitForTaskToComplete()
boolean	isMultipleConsumersSupported() Is multiple consumers supported?
boolean	isSingleton() Whether this class supports being singleton or not.
void	onStarted(RouteboxConsumer consumer)
void	onStarted(RouteboxProducer producer)
void	onStopped(RouteboxConsumer consumer)
void	onStopped(RouteboxProducer producer)
void	setQueue(BlockingQueue<Exchange> queue)
void	setWaitForTaskToComplete(WaitForTaskToComplete waitForTaskToComplete)

Methods inherited from class org.apache.camel.component.routebox.RouteboxEndpoint

getConfig, setConfig

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

configureProperties, createEndpointUri, createExchange, createExchange, createExchange, createPollingConsumer, doStart, doStop, equals, getCamelContext, getComponent, getEndpointKey, getEndpointUri, getExchangePattern, getExchangeType, getId, hashCode, isLenientProperties, isSynchronous, setCamelContext, setEndpointUri, setEndpointUriIfNotSpecified, setExchangePattern, setSynchronous, toString

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

addChildService, doResume, doShutdown, doSuspend, getStatus, getVersion, isRunAllowed, isStarted, isStarting, isStopped, isStopping, isSuspended, isSuspending, removeChildService, resume, shutdown, start, 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

configureProperties, createExchange, createExchange, createExchange, createPollingConsumer, getCamelContext, getEndpointKey, getEndpointUri, isLenientProperties, setCamelContext

Methods inherited from interface org.apache.camel.Service

start, stop

Constructor Detail

RouteboxSedaEndpoint

public RouteboxSedaEndpoint(String endpointUri,
                            RouteboxComponent component,
                            RouteboxConfiguration config)
                     throws Exception

Throws:

Exception

RouteboxSedaEndpoint

public RouteboxSedaEndpoint(String endpointUri,
                            RouteboxComponent component,
                            RouteboxConfiguration config,
                            BlockingQueue<Exchange> queue)
                     throws Exception

Throws:

Exception

Method Detail

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

Specified by:

createConsumer in interface Endpoint

Parameters:

processor - the given processor

Returns:

a newly created consumer

Throws:

Exception - can be thrown

createProducer

public Producer createProducer()
                        throws Exception

Description copied from interface: Endpoint

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

Specified by:

createProducer in interface Endpoint

Returns:

a newly created producer

Throws:

Exception - can be thrown

isSingleton

public boolean isSingleton()

Description copied from interface: IsSingleton

Whether this class supports being singleton or not.

Specified by:

isSingleton in interface IsSingleton

Returns:

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

onStarted

public void onStarted(RouteboxProducer producer)

onStopped

public void onStopped(RouteboxProducer producer)

onStarted

public void onStarted(RouteboxConsumer consumer)

onStopped

public void onStopped(RouteboxConsumer consumer)

getConsumers

public Set<RouteboxConsumer> getConsumers()

getProducers

public Set<RouteboxProducer> getProducers()

setQueue

public void setQueue(BlockingQueue<Exchange> queue)

getWaitForTaskToComplete

public WaitForTaskToComplete getWaitForTaskToComplete()

setWaitForTaskToComplete

public void setWaitForTaskToComplete(WaitForTaskToComplete waitForTaskToComplete)

getQueue

public BlockingQueue<Exchange> getQueue()

isMultipleConsumersSupported

public boolean isMultipleConsumersSupported()

Description copied from interface: MultipleConsumersSupport

Is multiple consumers supported?

Specified by:

isMultipleConsumersSupported in interface MultipleConsumersSupport

Returns:

true if multiple consumers is supported

getExchanges

public List<Exchange> getExchanges()

Description copied from interface: BrowsableEndpoint

Return the exchanges available on this endpoint

Specified by:

getExchanges in interface BrowsableEndpoint

Returns:

the exchanges on this endpoint