@UriEndpoint(scheme="ignite:events", title="Ignite Events", syntax="ignite:events:[endpointId]", label="nosql,cache,compute,messaging,data", consumerOnly=true, consumerClass=IgniteEventsConsumer.class) public class IgniteEventsEndpoint extends AbstractIgniteEndpoint
component
Constructor and Description |
---|
IgniteEventsEndpoint(String uri,
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() |
Set<Integer> |
getEvents()
Gets the event types to subscribe to.
|
void |
setClusterGroupExpression(ClusterGroupExpression clusterGroupExpression) |
void |
setEvents(Set<Integer> events)
Sets the event types to subscribe to as a
Set . |
void |
setEvents(String events)
Sets the event types to subscribe to as a comma-separated string of event constants as defined in
EventType . |
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 void setEvents(Set<Integer> events)
Set
.events
- public void setEvents(String events)
EventType
.
For example: EVT_CACHE_ENTRY_CREATED,EVT_CACHE_OBJECT_REMOVED,EVT_IGFS_DIR_CREATED.
events
- public ClusterGroupExpression getClusterGroupExpression()
public void setClusterGroupExpression(ClusterGroupExpression clusterGroupExpression)
Apache Camel