org.apache.camel.component.mybatis
Interface MyBatisProcessingStrategy

All Known Implementing Classes:

DefaultMyBatisProcessingStrategy

public interface MyBatisProcessingStrategy

Processing strategy for dealing with MyBatis when consuming.

Version:

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.

Method Detail

poll

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

Called when record is being queried.

Parameters:

consumer - the consumer

endpoint - the endpoint

Returns:

Results of the query as a List

Throws:

Exception - can be thrown in case of error

commit

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

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

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