|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectorg.apache.camel.support.ServiceSupport
org.apache.camel.impl.DefaultConsumer
org.apache.camel.impl.ScheduledPollConsumer
org.apache.camel.impl.ScheduledBatchPollingConsumer
org.apache.camel.component.krati.KratiConsumer
public class KratiConsumer
The Krati consumer.
Field Summary | |
---|---|
protected krati.store.DataStore<Object,Object> |
dataStore
|
protected KratiEndpoint |
endpoint
|
protected int |
maxMessagesPerPoll
|
Fields inherited from class org.apache.camel.impl.ScheduledBatchPollingConsumer |
---|
pendingExchanges, shutdownRunningTask |
Fields inherited from class org.apache.camel.impl.DefaultConsumer |
---|
log |
Fields inherited from class org.apache.camel.support.ServiceSupport |
---|
shutdown, shuttingdown, started, starting, stopped, stopping, suspended, suspending |
Constructor Summary | |
---|---|
KratiConsumer(KratiEndpoint endpoint,
org.apache.camel.Processor processor,
krati.store.DataStore<Object,Object> dataStore)
|
Method Summary | |
---|---|
protected int |
poll()
|
int |
processBatch(Queue<Object> exchanges)
|
Methods inherited from class org.apache.camel.impl.ScheduledBatchPollingConsumer |
---|
deferShutdown, getMaxMessagesPerPoll, getPendingExchangesSize, isBatchAllowed, prepareShutdown, setMaxMessagesPerPoll |
Methods inherited from class org.apache.camel.impl.ScheduledPollConsumer |
---|
afterPoll, beforePoll, doShutdown, doStart, doStop, doSuspend, getDelay, getInitialDelay, getPollStrategy, getRunLoggingLevel, getScheduledExecutorService, getTimeUnit, isPollAllowed, isPolling, isSendEmptyMessageWhenIdle, isStartScheduler, isUseFixedDelay, onInit, processEmptyMessage, run, setDelay, setInitialDelay, setPollStrategy, setRunLoggingLevel, setScheduledExecutorService, setSendEmptyMessageWhenIdle, setStartScheduler, setTimeUnit, setUseFixedDelay, startScheduler |
Methods inherited from class org.apache.camel.impl.DefaultConsumer |
---|
getAsyncProcessor, getEndpoint, getExceptionHandler, getProcessor, handleException, handleException, setExceptionHandler, toString |
Methods inherited from class org.apache.camel.support.ServiceSupport |
---|
doResume, getStatus, getVersion, isRunAllowed, isStarted, isStarting, isStopped, isStopping, isSuspended, isSuspending, resume, shutdown, start, stop, suspend |
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait |
Methods inherited from interface org.apache.camel.Consumer |
---|
getEndpoint |
Methods inherited from interface org.apache.camel.Service |
---|
start, stop |
Methods inherited from interface org.apache.camel.SuspendableService |
---|
isSuspended, resume, suspend |
Field Detail |
---|
protected final KratiEndpoint endpoint
protected krati.store.DataStore<Object,Object> dataStore
protected int maxMessagesPerPoll
Constructor Detail |
---|
public KratiConsumer(KratiEndpoint endpoint, org.apache.camel.Processor processor, krati.store.DataStore<Object,Object> dataStore)
Method Detail |
---|
protected int poll() throws Exception
poll
in class org.apache.camel.impl.ScheduledPollConsumer
Exception
public int processBatch(Queue<Object> exchanges) throws Exception
Exception
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |