@UriEndpoint(scheme="eventadmin", title="OSGi EventAdmin", syntax="eventadmin:topic", consumerClass=EventAdminConsumer.class, label="eventbus") public class EventAdminEndpoint extends org.apache.camel.impl.DefaultEndpoint
Constructor and Description |
---|
EventAdminEndpoint(String uri,
EventAdminComponent component,
String topic) |
Modifier and Type | Method and Description |
---|---|
org.apache.camel.Consumer |
createConsumer(org.apache.camel.Processor processor) |
org.apache.camel.Producer |
createProducer() |
EventAdminComponent |
getComponent() |
String |
getTopic()
Name of topic to listen or send to
|
boolean |
isSend() |
boolean |
isSingleton() |
void |
setSend(boolean send)
Whether to use 'send' or 'synchronous' deliver.
|
configureConsumer, configurePollingConsumer, configureProperties, createEndpointConfiguration, createEndpointUri, createExchange, createExchange, createExchange, createPollingConsumer, doStart, doStop, equals, getCamelContext, 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
public EventAdminEndpoint(String uri, EventAdminComponent component, String topic)
public String getTopic()
public boolean isSend()
public void setSend(boolean send)
public EventAdminComponent getComponent()
getComponent
in class org.apache.camel.impl.DefaultEndpoint
public org.apache.camel.Consumer createConsumer(org.apache.camel.Processor processor) throws Exception
Exception
public boolean isSingleton()
Apache Camel