@UriEndpoint(scheme="ignite:idgen", title="Ignite ID Generator", syntax="ignite:idgen:[name]", label="nosql,cache,compute", producerOnly=true) public class IgniteIdGenEndpoint extends AbstractIgniteEndpoint
component
shutdown, shuttingdown, started, starting, stopped, stopping, suspended, suspending
Constructor and Description |
---|
IgniteIdGenEndpoint(String endpointUri,
URI remainingUri,
Map<String,Object> parameters,
IgniteComponent igniteComponent) |
Modifier and Type | Method and Description |
---|---|
Consumer |
createConsumer(Processor processor)
Creates a new Event
Driven Consumer which consumes messages from the endpoint using the
given processor
|
Producer |
createProducer()
Creates a new producer which is used send messages into the endpoint
|
Integer |
getBatchSize() |
Long |
getInitialValue() |
String |
getName() |
IgniteIdGenOperation |
getOperation() |
void |
setBatchSize(Integer batchSize) |
void |
setInitialValue(Long initialValue) |
void |
setName(String name) |
void |
setOperation(IgniteIdGenOperation operation) |
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 Producer createProducer() throws Exception
Endpoint
Exception
- can be thrownpublic Consumer createConsumer(Processor processor) throws Exception
Endpoint
processor
- the given processorException
- can be thrownpublic String getName()
public void setName(String name)
public Long getInitialValue()
public void setInitialValue(Long initialValue)
public IgniteIdGenOperation getOperation()
public void setOperation(IgniteIdGenOperation operation)
public Integer getBatchSize()
public void setBatchSize(Integer batchSize)
Copyright © 2007–2016 The Apache Software Foundation. All rights reserved.