org.apache.camel.component.mybatis
Class MyBatisEndpoint
java.lang.Object
org.apache.camel.support.ServiceSupport
org.apache.camel.impl.DefaultEndpoint
org.apache.camel.impl.ScheduledPollEndpoint
org.apache.camel.impl.DefaultPollingEndpoint
org.apache.camel.component.mybatis.MyBatisEndpoint
- All Implemented Interfaces:
- org.apache.camel.CamelContextAware, org.apache.camel.Endpoint, org.apache.camel.IsSingleton, org.apache.camel.Service, org.apache.camel.ShutdownableService, org.apache.camel.spi.HasId, org.apache.camel.StatefulService, org.apache.camel.SuspendableService
public class MyBatisEndpoint
- extends org.apache.camel.impl.DefaultPollingEndpoint
- Version:
Fields inherited from class org.apache.camel.support.ServiceSupport |
shutdown, shuttingdown, started, starting, stopped, stopping, suspended, suspending |
Methods inherited from class org.apache.camel.impl.ScheduledPollEndpoint |
configureProperties |
Methods inherited from class org.apache.camel.impl.DefaultEndpoint |
configureConsumer, createEndpointConfiguration, createEndpointUri, createExchange, createExchange, createExchange, createPollingConsumer, doStart, doStop, equals, getCamelContext, getConsumerProperties, getEndpointConfiguration, getEndpointKey, getEndpointUri, getExchangePattern, getId, hashCode, isLenientProperties, isSynchronous, setCamelContext, setConsumerProperties, setEndpointConfiguration, setEndpointUri, setEndpointUriIfNotSpecified, setExchangePattern, setSynchronous, toString |
Methods inherited from class org.apache.camel.support.ServiceSupport |
doResume, doShutdown, doSuspend, getStatus, getVersion, isRunAllowed, isStarted, isStarting, isStopped, isStopping, isSuspended, isSuspending, resume, shutdown, start, stop, suspend |
Methods inherited from interface org.apache.camel.Service |
start, stop |
MyBatisEndpoint
public MyBatisEndpoint()
MyBatisEndpoint
public MyBatisEndpoint(String endpointUri,
org.apache.camel.Component component,
String statement)
createProducer
public org.apache.camel.Producer createProducer()
throws Exception
- Throws:
Exception
createConsumer
public org.apache.camel.Consumer createConsumer(org.apache.camel.Processor processor)
throws Exception
- Specified by:
createConsumer
in interface org.apache.camel.Endpoint
- Overrides:
createConsumer
in class org.apache.camel.impl.DefaultPollingEndpoint
- Throws:
Exception
isSingleton
public boolean isSingleton()
getComponent
public MyBatisComponent getComponent()
- Overrides:
getComponent
in class org.apache.camel.impl.DefaultEndpoint
getSqlSessionFactory
public org.apache.ibatis.session.SqlSessionFactory getSqlSessionFactory()
throws IOException
- Throws:
IOException
getStatement
public String getStatement()
setStatement
public void setStatement(String statement)
getStatementType
public StatementType getStatementType()
setStatementType
public void setStatementType(StatementType statementType)
getProcessingStrategy
public MyBatisProcessingStrategy getProcessingStrategy()
setProcessingStrategy
public void setProcessingStrategy(MyBatisProcessingStrategy processingStrategy)
getMaxMessagesPerPoll
public int getMaxMessagesPerPoll()
setMaxMessagesPerPoll
public void setMaxMessagesPerPoll(int maxMessagesPerPoll)
Apache CAMEL