public class GoraConsumer
extends org.apache.camel.impl.ScheduledPollConsumer
Consumer
.Constructor and Description |
---|
GoraConsumer(org.apache.camel.Endpoint endpoint,
org.apache.camel.Processor processor,
GoraConfiguration configuration,
org.apache.gora.store.DataStore<Object,org.apache.gora.persistency.Persistent> dataStore)
Consumer Constructor
|
Modifier and Type | Method and Description |
---|---|
protected int |
poll() |
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, processEmptyMessage, 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 GoraConsumer(org.apache.camel.Endpoint endpoint, org.apache.camel.Processor processor, GoraConfiguration configuration, org.apache.gora.store.DataStore<Object,org.apache.gora.persistency.Persistent> dataStore) throws ClassNotFoundException, NoSuchMethodException, InvocationTargetException, IllegalAccessException
endpoint
- Reference to the Camel-Gora endpointprocessor
- Reference to Consumer Processorconfiguration
- Reference to Camel-Gora endpoint configurationdataStore
- Reference to the datastoreClassNotFoundException
NoSuchMethodException
InvocationTargetException
IllegalAccessException
Apache Camel