public class DefaultMyBatisProcessingStrategy extends Object implements MyBatisProcessingStrategy
Constructor and Description |
---|
DefaultMyBatisProcessingStrategy() |
Modifier and Type | Method and Description |
---|---|
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.
|
public void commit(MyBatisEndpoint endpoint, org.apache.camel.Exchange exchange, Object data, String consumeStatements) throws Exception
MyBatisProcessingStrategy
commit
in interface MyBatisProcessingStrategy
endpoint
- the endpointexchange
- The exchange after it has been processeddata
- The original data delivered to the routeconsumeStatements
- Name of the statement(s) to run, will use SQL update. Use comma to provide multiple statements to run.Exception
- can be thrown in case of errorpublic List<?> poll(MyBatisConsumer consumer, MyBatisEndpoint endpoint) throws Exception
MyBatisProcessingStrategy
poll
in interface MyBatisProcessingStrategy
consumer
- the consumerendpoint
- the endpointList
Exception
- can be thrown in case of errorApache Camel