org.springframework.integration.jdbc
Class JdbcOutboundGateway
java.lang.Object
org.springframework.integration.context.IntegrationObjectSupport
org.springframework.integration.handler.AbstractMessageHandler
org.springframework.integration.handler.AbstractReplyProducingMessageHandler
org.springframework.integration.jdbc.JdbcOutboundGateway
- All Implemented Interfaces:
- BeanFactoryAware, BeanNameAware, InitializingBean, Ordered, NamedComponent, Orderable, MessageHandler, MessageProducer, TrackableComponent
public class JdbcOutboundGateway
- extends AbstractReplyProducingMessageHandler
- implements InitializingBean
- Since:
- 2.0
Methods inherited from class org.springframework.integration.context.IntegrationObjectSupport |
afterPropertiesSet, getBeanFactory, getComponentName, getConversionService, getTaskScheduler, setBeanFactory, setBeanName, setComponentName, setConversionService, setTaskScheduler, toString |
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait |
JdbcOutboundGateway
public JdbcOutboundGateway(javax.sql.DataSource dataSource,
java.lang.String updateQuery)
JdbcOutboundGateway
public JdbcOutboundGateway(javax.sql.DataSource dataSource,
java.lang.String updateQuery,
java.lang.String selectQuery)
JdbcOutboundGateway
public JdbcOutboundGateway(JdbcOperations jdbcOperations,
java.lang.String updateQuery)
JdbcOutboundGateway
public JdbcOutboundGateway(JdbcOperations jdbcOperations,
java.lang.String updateQuery,
java.lang.String selectQuery)
setMaxRowsPerPoll
public void setMaxRowsPerPoll(int maxRows)
onInit
protected void onInit()
- Description copied from class:
IntegrationObjectSupport
- Subclasses may implement this for initialization logic.
- Overrides:
onInit
in class AbstractReplyProducingMessageHandler
handleRequestMessage
protected java.lang.Object handleRequestMessage(Message<?> requestMessage)
- Description copied from class:
AbstractReplyProducingMessageHandler
- Subclasses must implement this method to handle the request Message. The return
value may be a Message, a MessageBuilder, or any plain Object. The base class
will handle the final creation of a reply Message from any of those starting
points. If the return value is null, the Message flow will end here.
- Specified by:
handleRequestMessage
in class AbstractReplyProducingMessageHandler
setKeysGenerated
public void setKeysGenerated(boolean keysGenerated)
- Flag to indicate that the update query is an insert with autogenerated keys, which will be logged at debug level.
- Parameters:
keysGenerated
- the flag value to set
setRequestSqlParameterSourceFactory
public void setRequestSqlParameterSourceFactory(SqlParameterSourceFactory sqlParameterSourceFactory)
setReplySqlParameterSourceFactory
public void setReplySqlParameterSourceFactory(SqlParameterSourceFactory sqlParameterSourceFactory)
setRowMapper
public void setRowMapper(RowMapper<?> rowMapper)