public class KratiConsumer
extends org.apache.camel.impl.ScheduledBatchPollingConsumer
Modifier and Type | Field and Description |
---|---|
protected krati.store.DataStore<Object,Object> |
dataStore |
protected KratiEndpoint |
endpoint |
Constructor and Description |
---|
KratiConsumer(KratiEndpoint endpoint,
org.apache.camel.Processor processor,
krati.store.DataStore<Object,Object> dataStore) |
Modifier and Type | Method and Description |
---|---|
protected int |
poll() |
int |
processBatch(Queue<Object> exchanges) |
deferShutdown, getMaxMessagesPerPoll, getPendingExchangesSize, isBatchAllowed, prepareShutdown, processEmptyMessage, setMaxMessagesPerPoll
afterPoll, beforePoll, doShutdown, doStart, doStop, doSuspend, getBackoffCounter, getBackoffErrorThreshold, getBackoffIdleThreshold, getBackoffMultiplier, getDelay, getInitialDelay, getPollStrategy, getRunLoggingLevel, getScheduledExecutorService, getScheduler, getSchedulerProperties, getTimeUnit, isGreedy, isPollAllowed, isPolling, isSchedulerStarted, isSendEmptyMessageWhenIdle, isStartScheduler, isUseFixedDelay, onInit, run, setBackoffErrorThreshold, setBackoffIdleThreshold, setBackoffMultiplier, setDelay, setGreedy, setInitialDelay, setPollStrategy, setRunLoggingLevel, setScheduledExecutorService, setScheduler, setSchedulerProperties, setSendEmptyMessageWhenIdle, setStartScheduler, setTimeUnit, setUseFixedDelay, startScheduler
createUoW, doneUoW, getAsyncProcessor, getEndpoint, getExceptionHandler, getProcessor, getRoute, handleException, handleException, setExceptionHandler, setRoute, toString
doResume, getStatus, getVersion, isRunAllowed, isStarted, isStarting, isStopped, isStopping, isStoppingOrStopped, isSuspended, isSuspending, isSuspendingOrSuspended, resume, shutdown, start, stop, suspend
protected final KratiEndpoint endpoint
public KratiConsumer(KratiEndpoint endpoint, org.apache.camel.Processor processor, krati.store.DataStore<Object,Object> dataStore)
Apache Camel