public class JcloudsBlobStoreConsumer
extends org.apache.camel.impl.ScheduledBatchPollingConsumer
Constructor and Description |
---|
JcloudsBlobStoreConsumer(JcloudsBlobStoreEndpoint endpoint,
org.apache.camel.Processor processor,
org.jclouds.blobstore.BlobStore blobStore) |
Modifier and Type | Method and Description |
---|---|
protected void |
doStart() |
protected int |
poll() |
int |
processBatch(Queue<Object> exchanges) |
deferShutdown, getMaxMessagesPerPoll, getPendingExchangesSize, isBatchAllowed, prepareShutdown, processEmptyMessage, setMaxMessagesPerPoll
afterPoll, beforePoll, doShutdown, 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
public JcloudsBlobStoreConsumer(JcloudsBlobStoreEndpoint endpoint, org.apache.camel.Processor processor, org.jclouds.blobstore.BlobStore blobStore)
Apache Camel