@UriEndpoint(scheme="ignite:messaging", title="Ignite Messaging", syntax="ignite:messaging:[topic]", label="nosql,cache,messaging", consumerClass=IgniteMessagingConsumer.class) public class IgniteMessagingEndpoint extends AbstractIgniteEndpoint
component
Constructor and Description |
---|
IgniteMessagingEndpoint(String endpointUri,
URI remainingUri,
Map<String,Object> parameters,
IgniteComponent igniteComponent) |
Modifier and Type | Method and Description |
---|---|
org.apache.camel.Consumer |
createConsumer(org.apache.camel.Processor processor) |
org.apache.camel.Producer |
createProducer() |
ClusterGroupExpression |
getClusterGroupExpression() |
IgniteMessagingSendMode |
getSendMode() |
Long |
getTimeout() |
String |
getTopic() |
void |
setClusterGroupExpression(ClusterGroupExpression clusterGroupExpression) |
void |
setSendMode(IgniteMessagingSendMode sendMode) |
void |
setTimeout(Long timeout) |
void |
setTopic(String topic) |
ignite, igniteComponent, isPropagateIncomingBodyIfNoReturnValue, isSingleton, isTreatCollectionsAsCacheObjects, setPropagateIncomingBodyIfNoReturnValue, setTreatCollectionsAsCacheObjects
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
public org.apache.camel.Consumer createConsumer(org.apache.camel.Processor processor) throws Exception
Exception
public String getTopic()
public void setTopic(String topic)
public ClusterGroupExpression getClusterGroupExpression()
public void setClusterGroupExpression(ClusterGroupExpression clusterGroupExpression)
public Long getTimeout()
public void setTimeout(Long timeout)
public IgniteMessagingSendMode getSendMode()
public void setSendMode(IgniteMessagingSendMode sendMode)
Apache Camel