public class RouteboxDirectEndpoint extends RouteboxEndpoint
Constructor and Description |
---|
RouteboxDirectEndpoint(String endpointUri)
Deprecated.
|
RouteboxDirectEndpoint(String endpointUri,
org.apache.camel.Component component) |
RouteboxDirectEndpoint(String uri,
org.apache.camel.Component component,
RouteboxConfiguration config) |
Modifier and Type | Method and Description |
---|---|
void |
addConsumer(RouteboxDirectConsumer consumer) |
org.apache.camel.Consumer |
createConsumer(org.apache.camel.Processor processor) |
org.apache.camel.Producer |
createProducer() |
RouteboxDirectConsumer |
getConsumer() |
boolean |
hasConsumer(RouteboxDirectConsumer consumer) |
boolean |
isSingleton() |
void |
removeConsumer(RouteboxDirectConsumer consumer) |
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
@Deprecated public RouteboxDirectEndpoint(String endpointUri)
public RouteboxDirectEndpoint(String endpointUri, org.apache.camel.Component component)
public RouteboxDirectEndpoint(String uri, org.apache.camel.Component component, RouteboxConfiguration config)
public org.apache.camel.Consumer createConsumer(org.apache.camel.Processor processor) throws Exception
Exception
public boolean isSingleton()
public void addConsumer(RouteboxDirectConsumer consumer)
public void removeConsumer(RouteboxDirectConsumer consumer)
public boolean hasConsumer(RouteboxDirectConsumer consumer)
public RouteboxDirectConsumer getConsumer()
Apache Camel