public class RouteboxSedaEndpoint extends RouteboxEndpoint implements org.apache.camel.AsyncEndpoint, org.apache.camel.spi.BrowsableEndpoint, org.apache.camel.MultipleConsumersSupport
Constructor and Description |
---|
RouteboxSedaEndpoint(String endpointUri,
RouteboxComponent component,
RouteboxConfiguration config) |
RouteboxSedaEndpoint(String endpointUri,
RouteboxComponent component,
RouteboxConfiguration config,
BlockingQueue<org.apache.camel.Exchange> queue) |
Modifier and Type | Method and Description |
---|---|
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) |
getConfig, setConfig
configureConsumer, configurePollingConsumer, configureProperties, createEndpointConfiguration, createEndpointUri, createExchange, createExchange, createExchange, createPollingConsumer, doStart, doStop, equals, getCamelContext, getComponent, getConsumerProperties, getEndpointConfiguration, getEndpointKey, getEndpointUri, getExceptionHandler, getExchangePattern, getId, getPollingConsumerBlockTimeout, getPollingConsumerQueueSize, hashCode, isBridgeErrorHandler, isLenientProperties, isPollingConsumerBlockWhenFull, isSynchronous, setBridgeErrorHandler, setCamelContext, setConsumerProperties, setEndpointConfiguration, setEndpointUri, setEndpointUriIfNotSpecified, setExceptionHandler, setExchangePattern, setPollingConsumerBlockTimeout, setPollingConsumerBlockWhenFull, setPollingConsumerQueueSize, setProperties, setSynchronous, toString
doResume, doShutdown, doSuspend, getStatus, getVersion, isRunAllowed, isStarted, isStarting, isStopped, isStopping, isStoppingOrStopped, isSuspended, isSuspending, isSuspendingOrSuspended, resume, shutdown, start, stop, suspend
clone, finalize, getClass, notify, notifyAll, wait, wait, wait
public RouteboxSedaEndpoint(String endpointUri, RouteboxComponent component, RouteboxConfiguration config) throws Exception
Exception
public RouteboxSedaEndpoint(String endpointUri, RouteboxComponent component, RouteboxConfiguration config, BlockingQueue<org.apache.camel.Exchange> queue) throws Exception
Exception
public org.apache.camel.Consumer createConsumer(org.apache.camel.Processor processor) throws Exception
createConsumer
in interface org.apache.camel.Endpoint
Exception
public org.apache.camel.Producer createProducer() throws Exception
createProducer
in interface org.apache.camel.Endpoint
Exception
public boolean isSingleton()
isSingleton
in interface org.apache.camel.IsSingleton
public void onStarted(RouteboxProducer producer)
public void onStopped(RouteboxProducer producer)
public void onStarted(RouteboxConsumer consumer)
public void onStopped(RouteboxConsumer consumer)
public Set<RouteboxConsumer> getConsumers()
public Set<RouteboxProducer> getProducers()
public void setQueue(BlockingQueue<org.apache.camel.Exchange> queue)
public org.apache.camel.WaitForTaskToComplete getWaitForTaskToComplete()
public void setWaitForTaskToComplete(org.apache.camel.WaitForTaskToComplete waitForTaskToComplete)
public BlockingQueue<org.apache.camel.Exchange> getQueue()
public boolean isMultipleConsumersSupported()
isMultipleConsumersSupported
in interface org.apache.camel.MultipleConsumersSupport
public List<org.apache.camel.Exchange> getExchanges()
getExchanges
in interface org.apache.camel.spi.BrowsableEndpoint
Apache Camel