@UriEndpoint(firstVersion="2.17.0", 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,
String remaining,
Map<String,Object> parameters,
IgniteMessagingComponent igniteComponent) |
IgniteMessagingEndpoint(String endpointUri,
URI remainingUri,
Map<String,Object> parameters,
IgniteComponent igniteComponent)
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
org.apache.camel.Consumer |
createConsumer(org.apache.camel.Processor processor) |
org.apache.camel.Producer |
createProducer() |
ClusterGroupExpression |
getClusterGroupExpression()
Gets the cluster group expression.
|
IgniteMessagingSendMode |
getSendMode()
Gets the send mode.
|
Long |
getTimeout()
Gets the timeout.
|
String |
getTopic()
Gets the topic name.
|
void |
setClusterGroupExpression(ClusterGroupExpression clusterGroupExpression)
The cluster group expression.
|
void |
setSendMode(IgniteMessagingSendMode sendMode)
The send mode to use.
|
void |
setTimeout(Long timeout)
The timeout for the send operation when using ordered messages.
|
void |
setTopic(String topic)
The topic name.
|
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
@Deprecated public IgniteMessagingEndpoint(String endpointUri, URI remainingUri, Map<String,Object> parameters, IgniteComponent igniteComponent)
public org.apache.camel.Consumer createConsumer(org.apache.camel.Processor processor) throws Exception
Exception
public String getTopic()
public void setTopic(String topic)
topic
- topic namepublic ClusterGroupExpression getClusterGroupExpression()
public void setClusterGroupExpression(ClusterGroupExpression clusterGroupExpression)
clusterGroupExpression
- cluster group expressionpublic Long getTimeout()
public void setTimeout(Long timeout)
timeout
- timeoutpublic IgniteMessagingSendMode getSendMode()
public void setSendMode(IgniteMessagingSendMode sendMode)
sendMode
- send modeApache Camel