public class GuavaEventBusComponent
extends org.apache.camel.impl.UriEndpointComponent
Constructor and Description |
---|
GuavaEventBusComponent() |
Modifier and Type | Method and Description |
---|---|
protected org.apache.camel.Endpoint |
createEndpoint(String uri,
String remaining,
Map<String,Object> parameters) |
com.google.common.eventbus.EventBus |
getEventBus() |
Class<?> |
getListenerInterface() |
void |
setEventBus(com.google.common.eventbus.EventBus eventBus)
To use the given Guava EventBus instance
|
void |
setListenerInterface(Class<?> listenerInterface)
The interface with method(s) marked with the @Subscribe annotation.
|
createComponentConfiguration, createParameterConfigurationMap, getEndpointClass, getParameterConfigurationMap, populateParameterConfigurationMap, setEndpointClass
afterConfiguration, createConfiguration, createEndpoint, doStart, doStop, getAndRemoveOrResolveReferenceParameter, getAndRemoveOrResolveReferenceParameter, getAndRemoveParameter, getAndRemoveParameter, getCamelContext, ifStartsWithReturnRemainder, preProcessUri, resolveAndRemoveReferenceListParameter, resolveAndRemoveReferenceListParameter, resolveAndRemoveReferenceParameter, resolveAndRemoveReferenceParameter, setCamelContext, setProperties, setProperties, useIntrospectionOnEndpoint, useRawUri, validateParameters, validateURI
protected org.apache.camel.Endpoint createEndpoint(String uri, String remaining, Map<String,Object> parameters) throws Exception
createEndpoint
in class org.apache.camel.impl.DefaultComponent
Exception
public com.google.common.eventbus.EventBus getEventBus()
public void setEventBus(com.google.common.eventbus.EventBus eventBus)
public Class<?> getListenerInterface()
public void setListenerInterface(Class<?> listenerInterface)
Apache Camel