org.apache.camel.component.ibatis.strategy
Interface IBatisProcessingStrategy

All Known Implementing Classes:

DefaultIBatisProcessingStategy

public interface IBatisProcessingStrategy

Processing strategy for dealing with IBatis when consuming.

Method Summary

void	commit(IBatisEndpoint endpoint, org.apache.camel.Exchange exchange, Object data, String consumeStatements) Commit callback if there are a statements to be run after processing.
int	getIsolation() Returns the transaction isolation level set on the processing strategy.
List<Object>	poll(IBatisConsumer consumer, IBatisEndpoint endpoint) Called when record is being queried.
void	setIsolation(int isolation) Sets the transaction isolation level on the processing strategy.

Method Detail

poll

List<Object> poll(IBatisConsumer consumer,
                  IBatisEndpoint 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(IBatisEndpoint 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

getIsolation

int getIsolation()

Returns the transaction isolation level set on the processing strategy.

Returns:

the transaction isolation level.

setIsolation

void setIsolation(int isolation)

Sets the transaction isolation level on the processing strategy.

Parameters:

isolation - the transaction isolation level.