org.apache.camel.component.mybatis
Class MyBatisConsumer
java.lang.Object
org.apache.camel.support.ServiceSupport
org.apache.camel.impl.DefaultConsumer
org.apache.camel.impl.ScheduledPollConsumer
org.apache.camel.impl.ScheduledBatchPollingConsumer
org.apache.camel.component.mybatis.MyBatisConsumer
- All Implemented Interfaces:
- Runnable, org.apache.camel.BatchConsumer, org.apache.camel.Consumer, org.apache.camel.PollingConsumerPollingStrategy, org.apache.camel.Service, org.apache.camel.ShutdownableService, org.apache.camel.spi.ShutdownAware, org.apache.camel.spi.ShutdownPrepared, org.apache.camel.StatefulService, org.apache.camel.SuspendableService
public class MyBatisConsumer
- extends org.apache.camel.impl.ScheduledBatchPollingConsumer
Consumer to read data from a database.
- Version:
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 |
Methods inherited from class org.apache.camel.impl.ScheduledBatchPollingConsumer |
deferShutdown, getMaxMessagesPerPoll, getPendingExchangesSize, isBatchAllowed, prepareShutdown, processEmptyMessage, 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, run, setDelay, setInitialDelay, setPollStrategy, setRunLoggingLevel, setScheduledExecutorService, setSendEmptyMessageWhenIdle, setStartScheduler, setTimeUnit, setUseFixedDelay, startScheduler |
Methods inherited from class org.apache.camel.impl.DefaultConsumer |
getAsyncProcessor, 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 interface org.apache.camel.Service |
start, stop |
Methods inherited from interface org.apache.camel.SuspendableService |
isSuspended, resume, suspend |
shutdownRunningTask
protected volatile org.apache.camel.ShutdownRunningTask shutdownRunningTask
pendingExchanges
protected volatile int pendingExchanges
MyBatisConsumer
public MyBatisConsumer(MyBatisEndpoint endpoint,
org.apache.camel.Processor processor)
getEndpoint
public MyBatisEndpoint getEndpoint()
- Specified by:
getEndpoint
in interface org.apache.camel.Consumer
- Overrides:
getEndpoint
in class org.apache.camel.impl.DefaultConsumer
poll
protected int poll()
throws Exception
- Polls the database
- Specified by:
poll
in class org.apache.camel.impl.ScheduledPollConsumer
- Throws:
Exception
processBatch
public int processBatch(Queue<Object> exchanges)
throws Exception
- Throws:
Exception
getOnConsume
public String getOnConsume()
- Gets the statement(s) to run after successful processing.
Use comma to separate multiple statements.
setOnConsume
public void setOnConsume(String onConsume)
- Sets the statement to run after successful processing.
Use comma to separate multiple statements.
isUseIterator
public boolean isUseIterator()
- Indicates how resultset should be delivered to the route
setUseIterator
public void setUseIterator(boolean useIterator)
- Sets how resultset should be delivered to route.
Indicates delivery as either a list or individual object.
defaults to true.
isRouteEmptyResultSet
public boolean isRouteEmptyResultSet()
- Indicates whether empty resultset should be allowed to be sent to the next hop or not
setRouteEmptyResultSet
public void setRouteEmptyResultSet(boolean routeEmptyResultSet)
- Sets whether empty resultset should be allowed to be sent to the next hop.
defaults to false. So the empty resultset will be filtered out.
Apache CAMEL