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

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

All Implemented Interfaces:

org.apache.camel.CamelContextAware, org.apache.camel.Endpoint, org.apache.camel.IsSingleton, org.apache.camel.MultipleConsumersSupport, org.apache.camel.Service, org.apache.camel.ShutdownableService, org.apache.camel.spi.BrowsableEndpoint, org.apache.camel.spi.HasId, org.apache.camel.StatefulService, org.apache.camel.SuspendableService

public class RouteboxSedaEndpoint
extends RouteboxEndpoint
implements org.apache.camel.spi.BrowsableEndpoint, org.apache.camel.MultipleConsumersSupport

Field Summary

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

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

Constructor Summary

RouteboxSedaEndpoint(String endpointUri, RouteboxComponent component, RouteboxConfiguration config)

RouteboxSedaEndpoint(String endpointUri, RouteboxComponent component, RouteboxConfiguration config, BlockingQueue<org.apache.camel.Exchange> queue)

Method Summary

org.apache.camel.Consumer	createConsumer(org.apache.camel.Processor processor)
org.apache.camel.Producer	createProducer()
Set<RouteboxConsumer>	getConsumers()
List<org.apache.camel.Exchange>	getExchanges()
Set<RouteboxProducer>	getProducers()
BlockingQueue<org.apache.camel.Exchange>	getQueue()
org.apache.camel.WaitForTaskToComplete	getWaitForTaskToComplete()
boolean	isMultipleConsumersSupported()
boolean	isSingleton()
void	onStarted(RouteboxConsumer consumer)
void	onStarted(RouteboxProducer producer)
void	onStopped(RouteboxConsumer consumer)
void	onStopped(RouteboxProducer producer)
void	setQueue(BlockingQueue<org.apache.camel.Exchange> queue)
void	setWaitForTaskToComplete(org.apache.camel.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, getEndpointConfiguration, getEndpointKey, getEndpointUri, getExchangePattern, getExchangeType, getId, hashCode, isLenientProperties, isSynchronous, setCamelContext, setEndpointUri, setEndpointUriIfNotSpecified, setExchangePattern, setSynchronous, toString

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

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

configureProperties, createExchange, createExchange, createExchange, createPollingConsumer, getCamelContext, getEndpointConfiguration, 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<org.apache.camel.Exchange> queue)
                     throws Exception

Throws:

Exception

Method Detail

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

createProducer

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

Specified by:

createProducer in interface org.apache.camel.Endpoint

Throws:

Exception

isSingleton

public boolean isSingleton()

Specified by:

isSingleton in interface org.apache.camel.IsSingleton

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<org.apache.camel.Exchange> queue)

getWaitForTaskToComplete

public org.apache.camel.WaitForTaskToComplete getWaitForTaskToComplete()

setWaitForTaskToComplete

public void setWaitForTaskToComplete(org.apache.camel.WaitForTaskToComplete waitForTaskToComplete)

getQueue

public BlockingQueue<org.apache.camel.Exchange> getQueue()

isMultipleConsumersSupported

public boolean isMultipleConsumersSupported()

Specified by:

isMultipleConsumersSupported in interface org.apache.camel.MultipleConsumersSupport

getExchanges

public List<org.apache.camel.Exchange> getExchanges()

Specified by:

getExchanges in interface org.apache.camel.spi.BrowsableEndpoint