public interface MyBatisProcessingStrategy
Modifier and Type | Method and Description |
---|---|
void |
commit(MyBatisEndpoint endpoint,
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.
|
List<?> poll(MyBatisConsumer consumer, MyBatisEndpoint endpoint) throws Exception
void commit(MyBatisEndpoint endpoint, Exchange exchange, Object data, String consumeStatements) throws Exception
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 errorCopyright © 2007–2016 The Apache Software Foundation. All rights reserved.