public final class AtomixQueueComponent extends AbstractAtomixClientComponent<AtomixQueueConfiguration>
Constructor and Description |
---|
AtomixQueueComponent() |
AtomixQueueComponent(org.apache.camel.CamelContext camelContext) |
Modifier and Type | Method and Description |
---|---|
protected org.apache.camel.Endpoint |
createEndpoint(String uri,
String remaining,
Map<String,Object> parameters) |
protected AtomixQueueConfiguration |
getComponentConfiguration() |
AtomixQueueConfiguration |
getConfiguration() |
void |
setConfiguration(AtomixQueueConfiguration configuration)
The shared component configuration
|
getAtomix, getConfigurationUri, getNodes, setAtomix, setConfigurationProperties, setConfigurationUri, setNodes, setNodes
afterConfiguration, createComponentConfiguration, createConfiguration, createEndpoint, doStart, doStop, getAndRemoveOrResolveReferenceParameter, getAndRemoveOrResolveReferenceParameter, getAndRemoveParameter, getAndRemoveParameter, getCamelContext, getExtension, getSupportedExtensions, ifStartsWithReturnRemainder, isResolvePropertyPlaceholders, preProcessUri, registerExtension, registerExtension, resolveAndRemoveReferenceListParameter, resolveAndRemoveReferenceListParameter, resolveAndRemoveReferenceParameter, resolveAndRemoveReferenceParameter, setCamelContext, setProperties, setProperties, setResolvePropertyPlaceholders, useIntrospectionOnEndpoint, useRawUri, validateParameters, validateURI
public AtomixQueueComponent()
public AtomixQueueComponent(org.apache.camel.CamelContext camelContext)
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 AtomixQueueConfiguration getConfiguration()
public void setConfiguration(AtomixQueueConfiguration configuration)
protected AtomixQueueConfiguration getComponentConfiguration()
getComponentConfiguration
in class AbstractAtomixClientComponent<AtomixQueueConfiguration>
Apache Camel