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:
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
DefaultMyBatisProcessingStrategy
public DefaultMyBatisProcessingStrategy()
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 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.
- 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 consumerendpoint
- the endpoint
- Returns:
- Results of the query as a
List
- Throws:
Exception
- can be thrown in case of error
Apache Camel