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.RouteAware, 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:

Field Summary

protected int	pendingExchanges
protected org.apache.camel.ShutdownRunningTask	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

MyBatisConsumer(MyBatisEndpoint endpoint, org.apache.camel.Processor processor)

Method Summary

MyBatisEndpoint	getEndpoint()
String	getOnConsume() Gets the statement(s) to run after successful processing.
boolean	isRouteEmptyResultSet() Indicates whether empty resultset should be allowed to be sent to the next hop or not
boolean	isUseIterator() Indicates how resultset should be delivered to the route
protected int	poll() Polls the database
int	processBatch(Queue<Object> exchanges)
void	setOnConsume(String onConsume) Sets the statement to run after successful processing.
void	setRouteEmptyResultSet(boolean routeEmptyResultSet) Sets whether empty resultset should be allowed to be sent to the next hop.
void	setUseIterator(boolean useIterator) Sets how resultset should be delivered to route.

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, 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

Methods inherited from class org.apache.camel.impl.DefaultConsumer

createUoW, doneUoW, getAsyncProcessor, getExceptionHandler, getProcessor, getRoute, handleException, handleException, setExceptionHandler, setRoute, toString

Methods inherited from class org.apache.camel.support.ServiceSupport

doResume, getStatus, getVersion, isRunAllowed, isStarted, isStarting, isStopped, isStopping, isStoppingOrStopped, 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.Service

start, stop

Methods inherited from interface org.apache.camel.SuspendableService

isSuspended, resume, suspend

Field Detail

shutdownRunningTask

protected volatile org.apache.camel.ShutdownRunningTask shutdownRunningTask

pendingExchanges

protected volatile int pendingExchanges

Constructor Detail

MyBatisConsumer

public MyBatisConsumer(MyBatisEndpoint endpoint,
                       org.apache.camel.Processor processor)

Method Detail

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.