Class JdbcPollingChannelAdapter

java.lang.Object

org.springframework.integration.util.AbstractExpressionEvaluator

org.springframework.integration.endpoint.AbstractMessageSource<Object>

org.springframework.integration.jdbc.inbound.JdbcPollingChannelAdapter

org.springframework.integration.jdbc.JdbcPollingChannelAdapter

All Implemented Interfaces:

Aware, BeanFactoryAware, BeanNameAware, DisposableBean, InitializingBean, MessageSource<Object>, IntegrationPattern, NamedComponent, IntegrationInboundManagement, IntegrationManagement

@Deprecated(forRemoval=true,
            since="7.0")
public class JdbcPollingChannelAdapter
extends JdbcPollingChannelAdapter

Deprecated, for removal: This API element is subject to removal in a future version.

since 7.0 in favor of JdbcPollingChannelAdapter

A polling channel adapter that creates messages from the payload returned by executing a select query. Optionally an update can be executed after the select in order to update processed rows.

Since:

2.0

Author:

Jonas Partner, Dave Syer, Artem Bilan

Nested Class Summary

Nested classes/interfaces inherited from interface IntegrationManagement

IntegrationManagement.ManagementOverrides

Field Summary

Fields inherited from class AbstractExpressionEvaluator

EXPRESSION_PARSER, logger

Fields inherited from interface IntegrationManagement

METER_PREFIX, RECEIVE_COUNTER_NAME, SEND_TIMER_NAME

Constructor Summary

Constructors

Constructor	Description
JdbcPollingChannelAdapter(DataSource dataSource, String selectQuery)	Deprecated, for removal: This API element is subject to removal in a future version. Constructor taking DataSource from which the DB Connection can be obtained and the select query to execute to retrieve new rows.
JdbcPollingChannelAdapter(JdbcOperations jdbcOperations, String selectQuery)	Deprecated, for removal: This API element is subject to removal in a future version. Constructor taking JdbcOperations instance to use for query execution and the select query to execute to retrieve new rows.

Method Summary

Methods inherited from class JdbcPollingChannelAdapter

doPoll, doReceive, getComponentType, onInit, setMaxRows, setRowMapper, setSelectQuery, setSelectSqlParameterSource, setUpdatePerRow, setUpdateSql, setUpdateSqlParameterSourceFactory

Methods inherited from class AbstractMessageSource

buildMessage, destroy, getComponentName, getManagedName, getManagedType, getOverrides, isLoggingEnabled, receive, registerMetricsCaptor, setBeanName, setHeaderExpressions, setLoggingEnabled, setManagedName, setManagedType

Methods inherited from class AbstractExpressionEvaluator

afterPropertiesSet, evaluateExpression, evaluateExpression, evaluateExpression, evaluateExpression, evaluateExpression, evaluateExpression, evaluateExpression, getBeanFactory, getEvaluationContext, getEvaluationContext, getMessageBuilderFactory, setBeanFactory, setConversionService, setSimpleEvaluationContext

Methods inherited from class Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface IntegrationManagement

getThisAs, isObserved, registerObservationRegistry

Methods inherited from interface MessageSource

getIntegrationPatternType

Methods inherited from interface NamedComponent

getBeanName

Constructor Details

JdbcPollingChannelAdapter

public JdbcPollingChannelAdapter(DataSource dataSource,
 String selectQuery)

Deprecated, for removal: This API element is subject to removal in a future version.

Constructor taking DataSource from which the DB Connection can be obtained and the select query to execute to retrieve new rows.

Parameters:

dataSource - Must not be null

selectQuery - query to execute

JdbcPollingChannelAdapter

public JdbcPollingChannelAdapter(JdbcOperations jdbcOperations,
 String selectQuery)

Deprecated, for removal: This API element is subject to removal in a future version.

Constructor taking JdbcOperations instance to use for query execution and the select query to execute to retrieve new rows.

Parameters:

jdbcOperations - instance to use for query execution

selectQuery - query to execute