org.apache.camel.component.mybatis
Class DefaultMyBatisProcessingStrategy

java.lang.Object
  org.apache.camel.component.mybatis.DefaultMyBatisProcessingStrategy

All Implemented Interfaces:

MyBatisProcessingStrategy

public class DefaultMyBatisProcessingStrategy
extends Object
implements MyBatisProcessingStrategy

Version:

Constructor Summary

DefaultMyBatisProcessingStrategy()

Method Summary

void	commit(MyBatisEndpoint endpoint, org.apache.camel.Exchange exchange, Object data, String consumeStatements) Commit callback if there are a statements to be run after processing.
List<?>	poll(MyBatisConsumer consumer, MyBatisEndpoint endpoint) Called when record is being queried.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

DefaultMyBatisProcessingStrategy

public DefaultMyBatisProcessingStrategy()

Method Detail

commit

public void commit(MyBatisEndpoint endpoint,
                   org.apache.camel.Exchange exchange,
                   Object data,
                   String consumeStatements)
            throws Exception

Description copied from interface: MyBatisProcessingStrategy

Commit callback if there are a statements to be run after processing.

Specified by:

commit in interface MyBatisProcessingStrategy

Parameters:

endpoint - the endpoint

exchange - The exchange after it has been processed

data - The original data delivered to the route

consumeStatements - Name of the statement(s) to run, will use SQL update. Use comma to provide multiple statements to run.

Throws:

Exception - can be thrown in case of error

poll

public List<?> poll(MyBatisConsumer consumer,
                    MyBatisEndpoint endpoint)
             throws Exception

Description copied from interface: MyBatisProcessingStrategy

Called when record is being queried.

Specified by:

poll in interface MyBatisProcessingStrategy

Parameters:

consumer - the consumer

endpoint - the endpoint

Returns:

Results of the query as a List

Throws:

Exception - can be thrown in case of error