org.apache.camel.component.ibatis
Class IBatisEndpoint
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.ibatis.IBatisEndpoint
- 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 IBatisEndpoint
- extends org.apache.camel.impl.DefaultPollingEndpoint
An
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 |
configurePollingConsumer, configureProperties, configureScheduledPollConsumerProperties |
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, setProperties, setSynchronous, toString |
Methods inherited from class org.apache.camel.support.ServiceSupport |
doResume, doShutdown, doSuspend, getStatus, getVersion, isRunAllowed, isStarted, isStarting, isStopped, isStopping, isStoppingOrStopped, isSuspended, isSuspending, resume, shutdown, start, stop, suspend |
Methods inherited from interface org.apache.camel.Service |
start, stop |
IBatisEndpoint
public IBatisEndpoint()
IBatisEndpoint
public IBatisEndpoint(String uri,
IBatisComponent component,
String statement)
throws Exception
- Throws:
Exception
getComponent
public IBatisComponent getComponent()
- Overrides:
getComponent
in class org.apache.camel.impl.DefaultEndpoint
isSingleton
public boolean isSingleton()
createProducer
public org.apache.camel.Producer createProducer()
throws Exception
- Throws:
Exception
createConsumer
public IBatisConsumer 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
getSqlMapClient
public com.ibatis.sqlmap.client.SqlMapClient getSqlMapClient()
throws IOException
- Gets the iBatis SqlMapClient
- Throws:
IOException
getProcessingStrategy
public IBatisProcessingStrategy getProcessingStrategy()
throws Exception
- Gets the IbatisProcessingStrategy to to use when consuming messages from the database
- Throws:
Exception
setStrategy
public void setStrategy(IBatisProcessingStrategy strategy)
getStatement
public String getStatement()
- Statement to run when polling or processing
setStatement
public void setStatement(String statement)
- Statement to run when polling or processing
isUseTransactions
public boolean isUseTransactions()
- Indicates if transactions should be used when calling statements. Useful if using a comma separated list when
consuming records.
setUseTransactions
public void setUseTransactions(boolean useTransactions)
- Sets indicator to use transactions for consuming and error handling statements.
getStatementType
public StatementType getStatementType()
setStatementType
public void setStatementType(StatementType statementType)
getMaxMessagesPerPoll
public int getMaxMessagesPerPoll()
setMaxMessagesPerPoll
public void setMaxMessagesPerPoll(int maxMessagesPerPoll)
getIsolation
public String getIsolation()
throws Exception
- Throws:
Exception
setIsolation
public void setIsolation(String isolation)
throws Exception
- Throws:
Exception
Apache Camel