@UriEndpoint(scheme="controlbus",
title="Control Bus",
syntax="controlbus:command:language",
producerOnly=true,
label="core,monitoring")
public class ControlBusEndpoint
extends DefaultEndpoint
shutdown, shuttingdown, started, starting, stopped, stopping, suspended, suspending| Constructor and Description |
|---|
ControlBusEndpoint(String endpointUri,
Component component) |
| Modifier and Type | Method and Description |
|---|---|
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
|
String |
getAction() |
ControlBusComponent |
getComponent()
Returns the component that created this endpoint.
|
Language |
getLanguage() |
LoggingLevel |
getLoggingLevel() |
String |
getRouteId() |
boolean |
isAsync() |
boolean |
isSingleton()
Whether this class supports being singleton or not.
|
void |
setAction(String action)
To denote an action that can be either: start, stop, or status.
|
void |
setAsync(boolean async)
Whether to execute the control bus task asynchronously.
|
void |
setLanguage(Language language)
Allows you to specify the name of a Language to use for evaluating the message body.
|
void |
setLoggingLevel(LoggingLevel loggingLevel)
Logging level used for logging when task is done, or if any exceptions occurred during processing the task.
|
void |
setRouteId(String routeId)
To specify a route by its id.
|
configureConsumer, configurePollingConsumer, configureProperties, createEndpointConfiguration, createEndpointUri, createExchange, createExchange, createExchange, createPollingConsumer, doStart, doStop, equals, getCamelContext, getConsumerProperties, getEndpointConfiguration, getEndpointKey, getEndpointUri, getExchangePattern, getId, getPollingConsumerQueueSize, hashCode, isLenientProperties, isPollingConsumerBlockWhenFull, isSynchronous, setCamelContext, setConsumerProperties, setEndpointConfiguration, setEndpointUri, setEndpointUriIfNotSpecified, setExchangePattern, setPollingConsumerBlockWhenFull, setPollingConsumerQueueSize, setProperties, setSynchronous, toStringdoResume, doShutdown, doSuspend, getStatus, getVersion, isRunAllowed, isStarted, isStarting, isStopped, isStopping, isStoppingOrStopped, isSuspended, isSuspending, isSuspendingOrSuspended, resume, shutdown, start, stop, suspendpublic Producer createProducer() throws Exception
EndpointException - can be thrownpublic Consumer createConsumer(Processor processor) throws Exception
Endpointprocessor - the given processorException - can be thrownpublic boolean isSingleton()
IsSingletonpublic ControlBusComponent getComponent()
DefaultEndpointgetComponent in class DefaultEndpointpublic Language getLanguage()
public void setLanguage(Language language)
public String getRouteId()
public void setRouteId(String routeId)
public String getAction()
public void setAction(String action)
public boolean isAsync()
public void setAsync(boolean async)
public LoggingLevel getLoggingLevel()
public void setLoggingLevel(LoggingLevel loggingLevel)
Apache Camel