Skip navigation links
A B C D E G H I J L M O P R S T V 

A

AbstractChannelMessageStoreQueryProvider - Class in org.springframework.integration.jdbc.store.channel
 
AbstractChannelMessageStoreQueryProvider() - Constructor for class org.springframework.integration.jdbc.store.channel.AbstractChannelMessageStoreQueryProvider
 
acquire(String) - Method in class org.springframework.integration.jdbc.lock.DefaultLockRepository
 
acquire(String) - Method in interface org.springframework.integration.jdbc.lock.LockRepository
 
addMessage(Message<T>) - Method in class org.springframework.integration.jdbc.store.JdbcMessageStore
 
addMessagesToGroup(Object, Message<?>...) - Method in class org.springframework.integration.jdbc.store.JdbcMessageStore
 
addMessageToGroup(Object, Message<?>) - Method in class org.springframework.integration.jdbc.store.JdbcChannelMessageStore
Store a message in the database.
addWhiteListPatterns(String...) - Method in class org.springframework.integration.jdbc.store.JdbcChannelMessageStore
Add patterns for packages/classes that are allowed to be deserialized.
addWhiteListPatterns(String...) - Method in class org.springframework.integration.jdbc.store.JdbcMessageStore
Add patterns for packages/classes that are allowed to be deserialized.
afterPropertiesSet() - Method in class org.springframework.integration.jdbc.lock.DefaultLockRepository
 
afterPropertiesSet() - Method in class org.springframework.integration.jdbc.metadata.JdbcMetadataStore
 
afterPropertiesSet() - Method in class org.springframework.integration.jdbc.store.JdbcChannelMessageStore
afterPropertiesSet() - Method in class org.springframework.integration.jdbc.StoredProcExecutor
Verifies parameters, sets the parameters on SimpleJdbcCallOperations and ensures the appropriate SqlParameterSourceFactory is defined when ProcedureParameter are passed in.

B

BeanPropertySqlParameterSourceFactory - Class in org.springframework.integration.jdbc
A default implementation of SqlParameterSourceFactory which creates an SqlParameterSource to reference bean properties in its input.
BeanPropertySqlParameterSourceFactory() - Constructor for class org.springframework.integration.jdbc.BeanPropertySqlParameterSourceFactory
 

C

ChannelMessageStorePreparedStatementSetter - Class in org.springframework.integration.jdbc.store.channel
Callback to be used with the JdbcChannelMessageStore.
ChannelMessageStorePreparedStatementSetter(SerializingConverter, LobHandler) - Constructor for class org.springframework.integration.jdbc.store.channel.ChannelMessageStorePreparedStatementSetter
Instantiate a ChannelMessageStorePreparedStatementSetter with the provided serializer and lobHandler, which both must not be null.
ChannelMessageStorePreparedStatementSetter() - Constructor for class org.springframework.integration.jdbc.store.channel.ChannelMessageStorePreparedStatementSetter
The default constructor for inheritors who are not interested in the message serialization to byte[].
ChannelMessageStoreQueryProvider - Interface in org.springframework.integration.jdbc.store.channel
Common interface used in order to configure the JdbcChannelMessageStore to provide database-specific queries.
close() - Method in class org.springframework.integration.jdbc.lock.DefaultLockRepository
 
close() - Method in interface org.springframework.integration.jdbc.lock.LockRepository
 
completeGroup(Object) - Method in class org.springframework.integration.jdbc.store.JdbcMessageStore
 
convertExpressions(Collection<ProcedureParameter>) - Static method in class org.springframework.integration.jdbc.storedproc.ProcedureParameter
Utility method that converts a Collection of ProcedureParameter to a Map containing only expression parameters.
convertStaticParameters(Collection<ProcedureParameter>) - Static method in class org.springframework.integration.jdbc.storedproc.ProcedureParameter
Utility method that converts a Collection of ProcedureParameter to a Map containing only static parameters.
convertToJdbcTypesEnum(String) - Static method in enum org.springframework.integration.jdbc.config.JdbcTypesEnum
Retrieves the matching enum constant for a provided String representation of the SQL Types.
CREATED_DATE_KEY - Static variable in class org.springframework.integration.jdbc.store.JdbcChannelMessageStore
Deprecated.
since 5.0. This constant isn't used any more.
CREATED_DATE_KEY - Static variable in class org.springframework.integration.jdbc.store.JdbcMessageStore
Deprecated.
since 5.0. This constant isn't used any more.
createParameterSource(Object) - Method in class org.springframework.integration.jdbc.BeanPropertySqlParameterSourceFactory
 
createParameterSource(Object) - Method in class org.springframework.integration.jdbc.ExpressionEvaluatingSqlParameterSourceFactory
 
createParameterSource(Object) - Method in interface org.springframework.integration.jdbc.SqlParameterSourceFactory
Return a new SqlParameterSource.
createParameterSourceNoCache(Object) - Method in class org.springframework.integration.jdbc.ExpressionEvaluatingSqlParameterSourceFactory
Create an expression evaluating SqlParameterSource that does not cache it's results.

D

DEFAULT_REGION - Static variable in class org.springframework.integration.jdbc.store.JdbcChannelMessageStore
Default region property, used to partition the message store.
DEFAULT_TABLE_PREFIX - Static variable in class org.springframework.integration.jdbc.lock.DefaultLockRepository
Default value for the table prefix property.
DEFAULT_TABLE_PREFIX - Static variable in class org.springframework.integration.jdbc.metadata.JdbcMetadataStore
Default value for the table prefix property.
DEFAULT_TABLE_PREFIX - Static variable in class org.springframework.integration.jdbc.store.JdbcChannelMessageStore
Default value for the table prefix property.
DEFAULT_TABLE_PREFIX - Static variable in class org.springframework.integration.jdbc.store.JdbcMessageStore
Default value for the table prefix property.
DEFAULT_TTL - Static variable in class org.springframework.integration.jdbc.lock.DefaultLockRepository
Default value for the time-to-live property.
DefaultLockRepository - Class in org.springframework.integration.jdbc.lock
The default implementation of the LockRepository based on the table from the script presented in the org/springframework/integration/jdbc/schema-*.sql.
DefaultLockRepository(DataSource) - Constructor for class org.springframework.integration.jdbc.lock.DefaultLockRepository
Constructor that initializes the client id that will be associated for all the locks persisted by the store instance to a random UUID.
DefaultLockRepository(DataSource, String) - Constructor for class org.springframework.integration.jdbc.lock.DefaultLockRepository
Constructor that allows the user to specify a client id that will be associated for all the locks persisted by the store instance.
delete(String) - Method in class org.springframework.integration.jdbc.lock.DefaultLockRepository
 
delete(String) - Method in interface org.springframework.integration.jdbc.lock.LockRepository
 
DerbyChannelMessageStoreQueryProvider - Class in org.springframework.integration.jdbc.store.channel
 
DerbyChannelMessageStoreQueryProvider() - Constructor for class org.springframework.integration.jdbc.store.channel.DerbyChannelMessageStoreQueryProvider
 
doInit() - Method in class org.springframework.integration.jdbc.JdbcOutboundGateway
 
doInit() - Method in class org.springframework.integration.jdbc.StoredProcOutboundGateway
 
doPoll(SqlParameterSource) - Method in class org.springframework.integration.jdbc.JdbcPollingChannelAdapter
 
doPollForMessage(String) - Method in class org.springframework.integration.jdbc.store.JdbcChannelMessageStore
This method executes a call to the DB to get the oldest Message in the MessageGroup which in the context of the JdbcChannelMessageStore means the channel identifier.
doPollForMessage(String) - Method in class org.springframework.integration.jdbc.store.JdbcMessageStore
This method executes a call to the DB to get the oldest Message in the MessageGroup Override this method if need to.
doReceive() - Method in class org.springframework.integration.jdbc.JdbcPollingChannelAdapter
Execute the select query and the update query if provided.
doReceive() - Method in class org.springframework.integration.jdbc.StoredProcPollingChannelAdapter
Execute the select query and the update query if provided.

E

executeStoredProcedure() - Method in class org.springframework.integration.jdbc.StoredProcExecutor
Execute a Stored Procedure or Function - Use when no Message is available to extract ProcedureParameter values from it.
executeStoredProcedure(Message<?>) - Method in class org.springframework.integration.jdbc.StoredProcExecutor
Execute a Stored Procedure or Function - Use with Message is available to extract ProcedureParameter values from it.
executeUpdateQuery(Message<?>, boolean) - Method in class org.springframework.integration.jdbc.JdbcMessageHandler
 
expireUnusedOlderThan(long) - Method in class org.springframework.integration.jdbc.lock.JdbcLockRegistry
 
ExpressionEvaluatingSqlParameterSourceFactory - Class in org.springframework.integration.jdbc
An implementation of SqlParameterSourceFactory which creates an SqlParameterSource that evaluates Spring EL expressions.
ExpressionEvaluatingSqlParameterSourceFactory() - Constructor for class org.springframework.integration.jdbc.ExpressionEvaluatingSqlParameterSourceFactory
 

G

get(String) - Method in class org.springframework.integration.jdbc.metadata.JdbcMetadataStore
 
getCode() - Method in enum org.springframework.integration.jdbc.config.JdbcTypesEnum
Get the numerical representation of the JDBC Type enum.
getComponentType() - Method in class org.springframework.integration.jdbc.JdbcMessageHandler
 
getComponentType() - Method in class org.springframework.integration.jdbc.JdbcOutboundGateway
 
getComponentType() - Method in class org.springframework.integration.jdbc.JdbcPollingChannelAdapter
 
getComponentType() - Method in class org.springframework.integration.jdbc.StoredProcMessageHandler
 
getComponentType() - Method in class org.springframework.integration.jdbc.StoredProcOutboundGateway
 
getComponentType() - Method in class org.springframework.integration.jdbc.StoredProcPollingChannelAdapter
 
getCountAllMessagesInGroupQuery() - Method in class org.springframework.integration.jdbc.store.channel.AbstractChannelMessageStoreQueryProvider
 
getCountAllMessagesInGroupQuery() - Method in interface org.springframework.integration.jdbc.store.channel.ChannelMessageStoreQueryProvider
Get the query used to retrieve a count of all messages currently persisted for a channel.
getCreateMessageQuery() - Method in class org.springframework.integration.jdbc.store.channel.AbstractChannelMessageStoreQueryProvider
 
getCreateMessageQuery() - Method in interface org.springframework.integration.jdbc.store.channel.ChannelMessageStoreQueryProvider
Query to add a single message to the database.
getCreateMessageQuery() - Method in class org.springframework.integration.jdbc.store.channel.H2ChannelMessageStoreQueryProvider
 
getCreateMessageQuery() - Method in class org.springframework.integration.jdbc.store.channel.HsqlChannelMessageStoreQueryProvider
 
getCreateMessageQuery() - Method in class org.springframework.integration.jdbc.store.channel.OracleChannelMessageStoreQueryProvider
 
getCreateMessageQuery() - Method in class org.springframework.integration.jdbc.store.channel.SqlServerChannelMessageStoreQueryProvider
 
getDeleteMessageGroupQuery() - Method in class org.springframework.integration.jdbc.store.channel.AbstractChannelMessageStoreQueryProvider
 
getDeleteMessageGroupQuery() - Method in interface org.springframework.integration.jdbc.store.channel.ChannelMessageStoreQueryProvider
Query to delete all messages that belong to a specific channel.
getDeleteMessageQuery() - Method in class org.springframework.integration.jdbc.store.channel.AbstractChannelMessageStoreQueryProvider
 
getDeleteMessageQuery() - Method in interface org.springframework.integration.jdbc.store.channel.ChannelMessageStoreQueryProvider
Query to delete a single message from the database.
getExpression() - Method in class org.springframework.integration.jdbc.storedproc.ProcedureParameter
 
getInputChannelAttributeName() - Method in class org.springframework.integration.jdbc.config.JdbcOutboundGatewayParser
 
getInputChannelAttributeName() - Method in class org.springframework.integration.jdbc.config.StoredProcOutboundGatewayParser
 
getJdbcCallOperationsCacheStatistics() - Method in class org.springframework.integration.jdbc.StoredProcExecutor
Allows for the retrieval of metrics (CacheStats) for the GuavaCacheWrapper#jdbcCallOperationsCache, which is used to store instances of SimpleJdbcCallOperations.
getJdbcCallOperationsCacheStatisticsAsMap() - Method in class org.springframework.integration.jdbc.StoredProcExecutor
Allows for the retrieval of metrics (CacheStats) for the GuavaCacheWrapper#jdbcCallOperationsCache.
getJdbcOperations() - Method in class org.springframework.integration.jdbc.store.JdbcMessageStore
To be used to get a reference to JdbcOperations in case this class is subclassed
getMessage(UUID) - Method in class org.springframework.integration.jdbc.store.JdbcMessageStore
 
getMessageCount() - Method in class org.springframework.integration.jdbc.store.JdbcMessageStore
 
getMessageCountForAllMessageGroups() - Method in class org.springframework.integration.jdbc.store.JdbcMessageStore
 
getMessageCountForRegionQuery() - Method in class org.springframework.integration.jdbc.store.channel.AbstractChannelMessageStoreQueryProvider
 
getMessageCountForRegionQuery() - Method in interface org.springframework.integration.jdbc.store.channel.ChannelMessageStoreQueryProvider
Query that retrieve a count of all messages for a region.
getMessageGroup(Object) - Method in class org.springframework.integration.jdbc.store.JdbcChannelMessageStore
Not fully used.
getMessageGroup(Object) - Method in class org.springframework.integration.jdbc.store.JdbcMessageStore
 
getMessageGroupCount() - Method in class org.springframework.integration.jdbc.store.JdbcChannelMessageStore
Method not implemented.
getMessageGroupCount() - Method in class org.springframework.integration.jdbc.store.JdbcMessageStore
 
getMessageGroupFactory() - Method in class org.springframework.integration.jdbc.store.JdbcChannelMessageStore
 
getMessageMetadata(UUID) - Method in class org.springframework.integration.jdbc.store.JdbcMessageStore
 
getMessageQuery() - Method in class org.springframework.integration.jdbc.store.channel.AbstractChannelMessageStoreQueryProvider
 
getMessageQuery() - Method in interface org.springframework.integration.jdbc.store.channel.ChannelMessageStoreQueryProvider
Query that retrieves a message for the provided message id, channel and region.
getMessagesForGroup(Object) - Method in class org.springframework.integration.jdbc.store.JdbcMessageStore
 
getName() - Method in class org.springframework.integration.jdbc.storedproc.ProcedureParameter
 
getOneMessageFromGroup(Object) - Method in class org.springframework.integration.jdbc.store.JdbcMessageStore
 
getPollFromGroupExcludeIdsQuery() - Method in interface org.springframework.integration.jdbc.store.channel.ChannelMessageStoreQueryProvider
Get the query used to retrieve the oldest message for a channel excluding messages that match the provided message ids.
getPollFromGroupExcludeIdsQuery() - Method in class org.springframework.integration.jdbc.store.channel.DerbyChannelMessageStoreQueryProvider
 
getPollFromGroupExcludeIdsQuery() - Method in class org.springframework.integration.jdbc.store.channel.H2ChannelMessageStoreQueryProvider
 
getPollFromGroupExcludeIdsQuery() - Method in class org.springframework.integration.jdbc.store.channel.HsqlChannelMessageStoreQueryProvider
 
getPollFromGroupExcludeIdsQuery() - Method in class org.springframework.integration.jdbc.store.channel.MySqlChannelMessageStoreQueryProvider
 
getPollFromGroupExcludeIdsQuery() - Method in class org.springframework.integration.jdbc.store.channel.OracleChannelMessageStoreQueryProvider
 
getPollFromGroupExcludeIdsQuery() - Method in class org.springframework.integration.jdbc.store.channel.PostgresChannelMessageStoreQueryProvider
 
getPollFromGroupExcludeIdsQuery() - Method in class org.springframework.integration.jdbc.store.channel.SqlServerChannelMessageStoreQueryProvider
 
getPollFromGroupQuery() - Method in interface org.springframework.integration.jdbc.store.channel.ChannelMessageStoreQueryProvider
Get the query used to retrieve the oldest message for a channel.
getPollFromGroupQuery() - Method in class org.springframework.integration.jdbc.store.channel.DerbyChannelMessageStoreQueryProvider
 
getPollFromGroupQuery() - Method in class org.springframework.integration.jdbc.store.channel.H2ChannelMessageStoreQueryProvider
 
getPollFromGroupQuery() - Method in class org.springframework.integration.jdbc.store.channel.HsqlChannelMessageStoreQueryProvider
 
getPollFromGroupQuery() - Method in class org.springframework.integration.jdbc.store.channel.MySqlChannelMessageStoreQueryProvider
 
getPollFromGroupQuery() - Method in class org.springframework.integration.jdbc.store.channel.OracleChannelMessageStoreQueryProvider
 
getPollFromGroupQuery() - Method in class org.springframework.integration.jdbc.store.channel.PostgresChannelMessageStoreQueryProvider
 
getPollFromGroupQuery() - Method in class org.springframework.integration.jdbc.store.channel.SqlServerChannelMessageStoreQueryProvider
 
getPriorityPollFromGroupExcludeIdsQuery() - Method in interface org.springframework.integration.jdbc.store.channel.ChannelMessageStoreQueryProvider
Get the query used to retrieve the oldest message by priority for a channel excluding messages that match the provided message ids.
getPriorityPollFromGroupExcludeIdsQuery() - Method in class org.springframework.integration.jdbc.store.channel.DerbyChannelMessageStoreQueryProvider
 
getPriorityPollFromGroupExcludeIdsQuery() - Method in class org.springframework.integration.jdbc.store.channel.H2ChannelMessageStoreQueryProvider
 
getPriorityPollFromGroupExcludeIdsQuery() - Method in class org.springframework.integration.jdbc.store.channel.HsqlChannelMessageStoreQueryProvider
 
getPriorityPollFromGroupExcludeIdsQuery() - Method in class org.springframework.integration.jdbc.store.channel.MySqlChannelMessageStoreQueryProvider
 
getPriorityPollFromGroupExcludeIdsQuery() - Method in class org.springframework.integration.jdbc.store.channel.OracleChannelMessageStoreQueryProvider
 
getPriorityPollFromGroupExcludeIdsQuery() - Method in class org.springframework.integration.jdbc.store.channel.PostgresChannelMessageStoreQueryProvider
 
getPriorityPollFromGroupExcludeIdsQuery() - Method in class org.springframework.integration.jdbc.store.channel.SqlServerChannelMessageStoreQueryProvider
 
getPriorityPollFromGroupQuery() - Method in interface org.springframework.integration.jdbc.store.channel.ChannelMessageStoreQueryProvider
Get the query used to retrieve the oldest message by priority for a channel.
getPriorityPollFromGroupQuery() - Method in class org.springframework.integration.jdbc.store.channel.DerbyChannelMessageStoreQueryProvider
 
getPriorityPollFromGroupQuery() - Method in class org.springframework.integration.jdbc.store.channel.H2ChannelMessageStoreQueryProvider
 
getPriorityPollFromGroupQuery() - Method in class org.springframework.integration.jdbc.store.channel.HsqlChannelMessageStoreQueryProvider
 
getPriorityPollFromGroupQuery() - Method in class org.springframework.integration.jdbc.store.channel.MySqlChannelMessageStoreQueryProvider
 
getPriorityPollFromGroupQuery() - Method in class org.springframework.integration.jdbc.store.channel.OracleChannelMessageStoreQueryProvider
 
getPriorityPollFromGroupQuery() - Method in class org.springframework.integration.jdbc.store.channel.PostgresChannelMessageStoreQueryProvider
 
getPriorityPollFromGroupQuery() - Method in class org.springframework.integration.jdbc.store.channel.SqlServerChannelMessageStoreQueryProvider
 
getProcedureParameterBeanDefinitions(Element, ParserContext) - Static method in class org.springframework.integration.jdbc.config.StoredProcParserUtils
 
getQuery(String) - Method in class org.springframework.integration.jdbc.store.JdbcChannelMessageStore
Replace patterns in the input to produce a valid SQL query.
getQuery(JdbcMessageStore.Query) - Method in class org.springframework.integration.jdbc.store.JdbcMessageStore
Replace patterns in the input to produce a valid SQL query.
getReturningResultsetBeanDefinitions(Element, ParserContext) - Static method in class org.springframework.integration.jdbc.config.StoredProcParserUtils
 
getSizeOfIdCache() - Method in class org.springframework.integration.jdbc.store.JdbcChannelMessageStore
Returns the size of the Message Id Cache, which caches Message Ids for those messages that are currently being processed.
getSqlParameterDefinitionBeanDefinitions(Element, ParserContext) - Static method in class org.springframework.integration.jdbc.config.StoredProcParserUtils
 
getStoredProcedureName() - Method in class org.springframework.integration.jdbc.StoredProcExecutor
 
getStoredProcedureNameExpressionAsString() - Method in class org.springframework.integration.jdbc.StoredProcExecutor
 
getStoredProcExecutorBuilder(Element, ParserContext) - Static method in class org.springframework.integration.jdbc.config.StoredProcParserUtils
Create a new BeanDefinitionBuilder for the class StoredProcExecutor.
getValue() - Method in class org.springframework.integration.jdbc.storedproc.ProcedureParameter
 

H

H2ChannelMessageStoreQueryProvider - Class in org.springframework.integration.jdbc.store.channel
 
H2ChannelMessageStoreQueryProvider() - Constructor for class org.springframework.integration.jdbc.store.channel.H2ChannelMessageStoreQueryProvider
 
handleMessageInternal(Message<?>) - Method in class org.springframework.integration.jdbc.JdbcMessageHandler
Executes the update, passing the message into the SqlParameterSourceFactory.
handleMessageInternal(Message<?>) - Method in class org.springframework.integration.jdbc.StoredProcMessageHandler
Executes the Stored procedure, delegates to executeStoredProcedure(...).
handleRequestMessage(Message<?>) - Method in class org.springframework.integration.jdbc.JdbcOutboundGateway
 
handleRequestMessage(Message<?>) - Method in class org.springframework.integration.jdbc.StoredProcOutboundGateway
 
HsqlChannelMessageStoreQueryProvider - Class in org.springframework.integration.jdbc.store.channel
 
HsqlChannelMessageStoreQueryProvider() - Constructor for class org.springframework.integration.jdbc.store.channel.HsqlChannelMessageStoreQueryProvider
 

I

init() - Method in class org.springframework.integration.jdbc.config.JdbcNamespaceHandler
 
isAcquired(String) - Method in class org.springframework.integration.jdbc.lock.DefaultLockRepository
 
isAcquired(String) - Method in interface org.springframework.integration.jdbc.lock.LockRepository
 
isPriorityEnabled() - Method in class org.springframework.integration.jdbc.store.JdbcChannelMessageStore
 
iterator() - Method in class org.springframework.integration.jdbc.store.JdbcMessageStore
 

J

JdbcChannelMessageStore - Class in org.springframework.integration.jdbc.store
Channel-specific implementation of MessageGroupStore using a relational database via JDBC.
JdbcChannelMessageStore() - Constructor for class org.springframework.integration.jdbc.store.JdbcChannelMessageStore
Convenient constructor for configuration use.
JdbcChannelMessageStore(DataSource) - Constructor for class org.springframework.integration.jdbc.store.JdbcChannelMessageStore
Create a MessageStore with all mandatory properties.
JdbcLockRegistry - Class in org.springframework.integration.jdbc.lock
A LockRegistry using a shared database to co-ordinate the locks.
JdbcLockRegistry(LockRepository) - Constructor for class org.springframework.integration.jdbc.lock.JdbcLockRegistry
 
JdbcMessageHandler - Class in org.springframework.integration.jdbc
A message handler that executes an SQL update.
JdbcMessageHandler(DataSource, String) - Constructor for class org.springframework.integration.jdbc.JdbcMessageHandler
Constructor taking DataSource from which the DB Connection can be obtained and the select query to execute to retrieve new rows.
JdbcMessageHandler(JdbcOperations, String) - Constructor for class org.springframework.integration.jdbc.JdbcMessageHandler
Constructor taking JdbcOperations instance to use for query execution and the select query to execute to retrieve new rows.
JdbcMessageHandlerParser - Class in org.springframework.integration.jdbc.config
 
JdbcMessageHandlerParser() - Constructor for class org.springframework.integration.jdbc.config.JdbcMessageHandlerParser
 
JdbcMessageStore - Class in org.springframework.integration.jdbc.store
Implementation of MessageStore using a relational database via JDBC.
JdbcMessageStore(DataSource) - Constructor for class org.springframework.integration.jdbc.store.JdbcMessageStore
Create a MessageStore with all mandatory properties.
JdbcMessageStore(JdbcOperations) - Constructor for class org.springframework.integration.jdbc.store.JdbcMessageStore
Create a MessageStore with all mandatory properties.
JdbcMessageStoreParser - Class in org.springframework.integration.jdbc.config
Parser for JdbcMessageStore.
JdbcMessageStoreParser() - Constructor for class org.springframework.integration.jdbc.config.JdbcMessageStoreParser
 
JdbcMetadataStore - Class in org.springframework.integration.jdbc.metadata
Implementation of MetadataStore using a relational database via JDBC.
JdbcMetadataStore(DataSource) - Constructor for class org.springframework.integration.jdbc.metadata.JdbcMetadataStore
Instantiate a JdbcMetadataStore using provided dataSource DataSource.
JdbcMetadataStore(JdbcOperations) - Constructor for class org.springframework.integration.jdbc.metadata.JdbcMetadataStore
Instantiate a JdbcMetadataStore using provided jdbcOperations JdbcOperations.
JdbcNamespaceHandler - Class in org.springframework.integration.jdbc.config
Namespace handler for the integration JDBC schema.
JdbcNamespaceHandler() - Constructor for class org.springframework.integration.jdbc.config.JdbcNamespaceHandler
 
JdbcOutboundGateway - Class in org.springframework.integration.jdbc
 
JdbcOutboundGateway(DataSource, String) - Constructor for class org.springframework.integration.jdbc.JdbcOutboundGateway
 
JdbcOutboundGateway(DataSource, String, String) - Constructor for class org.springframework.integration.jdbc.JdbcOutboundGateway
 
JdbcOutboundGateway(JdbcOperations, String) - Constructor for class org.springframework.integration.jdbc.JdbcOutboundGateway
 
JdbcOutboundGateway(JdbcOperations, String, String) - Constructor for class org.springframework.integration.jdbc.JdbcOutboundGateway
 
JdbcOutboundGatewayParser - Class in org.springframework.integration.jdbc.config
 
JdbcOutboundGatewayParser() - Constructor for class org.springframework.integration.jdbc.config.JdbcOutboundGatewayParser
 
JdbcPollingChannelAdapter - Class in org.springframework.integration.jdbc
A polling channel adapter that creates messages from the payload returned by executing a select query.
JdbcPollingChannelAdapter(DataSource, String) - Constructor for class org.springframework.integration.jdbc.JdbcPollingChannelAdapter
Constructor taking DataSource from which the DB Connection can be obtained and the select query to execute to retrieve new rows.
JdbcPollingChannelAdapter(JdbcOperations, String) - Constructor for class org.springframework.integration.jdbc.JdbcPollingChannelAdapter
Constructor taking JdbcOperations instance to use for query execution and the select query to execute to retrieve new rows.
JdbcPollingChannelAdapterParser - Class in org.springframework.integration.jdbc.config
JdbcPollingChannelAdapterParser() - Constructor for class org.springframework.integration.jdbc.config.JdbcPollingChannelAdapterParser
 
JdbcTypesEnum - Enum in org.springframework.integration.jdbc.config
This Enumeration provides a handy wrapper around Types.

L

LockRepository - Interface in org.springframework.integration.jdbc.lock
Encapsulation of the SQL shunting that is needed for locks.

M

mapRow(ResultSet, int) - Method in class org.springframework.integration.jdbc.store.channel.MessageRowMapper
 
messageGroupSize(Object) - Method in class org.springframework.integration.jdbc.store.JdbcChannelMessageStore
Returns the number of messages persisted for the specified channel id (groupId) and the specified region (JdbcChannelMessageStore.setRegion(String)).
messageGroupSize(Object) - Method in class org.springframework.integration.jdbc.store.JdbcMessageStore
 
MessagePreparedStatementSetter - Interface in org.springframework.integration.jdbc
The callback to be used with the JdbcMessageHandler as an alternative to the SqlParameterSourceFactory.
MessageRowMapper - Class in org.springframework.integration.jdbc.store.channel
Convenience class to be used to unpack a Message from a result set row.
MessageRowMapper(WhiteListDeserializingConverter, LobHandler) - Constructor for class org.springframework.integration.jdbc.store.channel.MessageRowMapper
 
MySqlChannelMessageStoreQueryProvider - Class in org.springframework.integration.jdbc.store.channel
 
MySqlChannelMessageStoreQueryProvider() - Constructor for class org.springframework.integration.jdbc.store.channel.MySqlChannelMessageStoreQueryProvider
 

O

obtain(Object) - Method in class org.springframework.integration.jdbc.lock.JdbcLockRegistry
 
onInit() - Method in class org.springframework.integration.jdbc.ExpressionEvaluatingSqlParameterSourceFactory
 
onInit() - Method in class org.springframework.integration.jdbc.JdbcMessageHandler
 
onInit() - Method in class org.springframework.integration.jdbc.JdbcPollingChannelAdapter
 
OracleChannelMessageStoreQueryProvider - Class in org.springframework.integration.jdbc.store.channel
Contains Oracle-specific queries for the JdbcChannelMessageStore.
OracleChannelMessageStoreQueryProvider() - Constructor for class org.springframework.integration.jdbc.store.channel.OracleChannelMessageStoreQueryProvider
 
org.springframework.integration.jdbc - package org.springframework.integration.jdbc
Root package of the Spring Integration JDBC module, which contains various JDBC and Stored Procedure/Function supporting components.
org.springframework.integration.jdbc.config - package org.springframework.integration.jdbc.config
Contains parser classes for the JDBC namespace support.
org.springframework.integration.jdbc.lock - package org.springframework.integration.jdbc.lock
 
org.springframework.integration.jdbc.metadata - package org.springframework.integration.jdbc.metadata
Contains JDBC implementation of MetadataStore
org.springframework.integration.jdbc.store - package org.springframework.integration.jdbc.store
Provides JDBC-backed Message Store implementations.
org.springframework.integration.jdbc.store.channel - package org.springframework.integration.jdbc.store.channel
Provides support classes for the JdbcChannelMessageStore.
org.springframework.integration.jdbc.storedproc - package org.springframework.integration.jdbc.storedproc
Provides Stored Procedure/Function supporting classes.

P

parseConsumer(Element, ParserContext) - Method in class org.springframework.integration.jdbc.config.JdbcMessageHandlerParser
 
parseConsumer(Element, ParserContext) - Method in class org.springframework.integration.jdbc.config.StoredProcMessageHandlerParser
 
parseHandler(Element, ParserContext) - Method in class org.springframework.integration.jdbc.config.JdbcOutboundGatewayParser
 
parseHandler(Element, ParserContext) - Method in class org.springframework.integration.jdbc.config.StoredProcOutboundGatewayParser
 
parseInternal(Element, ParserContext) - Method in class org.springframework.integration.jdbc.config.JdbcMessageStoreParser
 
parseSource(Element, ParserContext) - Method in class org.springframework.integration.jdbc.config.JdbcPollingChannelAdapterParser
 
parseSource(Element, ParserContext) - Method in class org.springframework.integration.jdbc.config.StoredProcPollingChannelAdapterParser
 
pollMessageFromGroup(Object) - Method in class org.springframework.integration.jdbc.store.JdbcChannelMessageStore
Polls the database for a new message that is persisted for the given group id which represents the channel identifier.
pollMessageFromGroup(Object) - Method in class org.springframework.integration.jdbc.store.JdbcMessageStore
 
PostgresChannelMessageStoreQueryProvider - Class in org.springframework.integration.jdbc.store.channel
 
PostgresChannelMessageStoreQueryProvider() - Constructor for class org.springframework.integration.jdbc.store.channel.PostgresChannelMessageStoreQueryProvider
 
ProcedureParameter - Class in org.springframework.integration.jdbc.storedproc
Abstraction of Procedure parameters allowing to provide static parameters and SpEl Expression based parameters.
ProcedureParameter(String, Object, String) - Constructor for class org.springframework.integration.jdbc.storedproc.ProcedureParameter
Instantiates a new Procedure Parameter.
ProcedureParameter() - Constructor for class org.springframework.integration.jdbc.storedproc.ProcedureParameter
Default constructor.
put(String, String) - Method in class org.springframework.integration.jdbc.metadata.JdbcMetadataStore
 
putIfAbsent(String, String) - Method in class org.springframework.integration.jdbc.metadata.JdbcMetadataStore
 

R

remove(String) - Method in class org.springframework.integration.jdbc.metadata.JdbcMetadataStore
 
removeFromIdCache(String) - Method in class org.springframework.integration.jdbc.store.JdbcChannelMessageStore
Remove a Message Id from the idCache.
removeMessage(UUID) - Method in class org.springframework.integration.jdbc.store.JdbcMessageStore
 
removeMessageGroup(Object) - Method in class org.springframework.integration.jdbc.store.JdbcChannelMessageStore
 
removeMessageGroup(Object) - Method in class org.springframework.integration.jdbc.store.JdbcMessageStore
 
removeMessagesFromGroup(Object, Collection<Message<?>>) - Method in class org.springframework.integration.jdbc.store.JdbcMessageStore
 
replace(String, String, String) - Method in class org.springframework.integration.jdbc.metadata.JdbcMetadataStore
 

S

SAVED_KEY - Static variable in class org.springframework.integration.jdbc.store.JdbcChannelMessageStore
Deprecated.
since 5.0. This constant isn't used any more.
SAVED_KEY - Static variable in class org.springframework.integration.jdbc.store.JdbcMessageStore
Deprecated.
since 5.0. This constant isn't used any more.
setBeanFactory(BeanFactory) - Method in class org.springframework.integration.jdbc.StoredProcExecutor
Allows to set the optional BeanFactory which is used to add a BeanResolver to the StandardEvaluationContext.
setChannelMessageStoreQueryProvider(ChannelMessageStoreQueryProvider) - Method in class org.springframework.integration.jdbc.store.JdbcChannelMessageStore
Sets the database specific ChannelMessageStoreQueryProvider to use.
setDataSource(DataSource) - Method in class org.springframework.integration.jdbc.store.JdbcChannelMessageStore
The JDBC DataSource to use when interacting with the database.
setDeserializer(Deserializer<? extends Message<?>>) - Method in class org.springframework.integration.jdbc.store.JdbcChannelMessageStore
A converter for deserializing byte arrays to messages.
setDeserializer(Deserializer<? extends Message<?>>) - Method in class org.springframework.integration.jdbc.store.JdbcMessageStore
A converter for deserializing byte arrays to messages.
setExpectSingleResult(boolean) - Method in class org.springframework.integration.jdbc.StoredProcOutboundGateway
This parameter indicates that only one result object shall be returned from the Stored Procedure/Function Call.
setExpectSingleResult(boolean) - Method in class org.springframework.integration.jdbc.StoredProcPollingChannelAdapter
This parameter indicates that only one result object shall be returned from the Stored Procedure/Function Call.
setExpression(String) - Method in class org.springframework.integration.jdbc.storedproc.ProcedureParameter
 
setIgnoreColumnMetaData(boolean) - Method in class org.springframework.integration.jdbc.StoredProcExecutor
For fully supported databases, the underlying SimpleJdbcCall can retrieve the parameter information for the to be invoked Stored Procedure from the JDBC Meta-data.
setIsFunction(boolean) - Method in class org.springframework.integration.jdbc.StoredProcExecutor
Indicates whether a Stored Procedure or a Function is being executed.
setJdbcCallOperationsCacheSize(int) - Method in class org.springframework.integration.jdbc.StoredProcExecutor
Defines the maximum number of SimpleJdbcCallOperations (SimpleJdbcCall) instances to be held by GuavaCacheWrapper#jdbcCallOperationsCache.
setJdbcTemplate(JdbcTemplate) - Method in class org.springframework.integration.jdbc.store.JdbcChannelMessageStore
The JdbcOperations to use when interacting with the database.
setKeysGenerated(boolean) - Method in class org.springframework.integration.jdbc.JdbcMessageHandler
Flag to indicate that the update query is an insert with auto-generated keys, which will be logged at debug level.
setKeysGenerated(boolean) - Method in class org.springframework.integration.jdbc.JdbcOutboundGateway
Flag to indicate that the update query is an insert with auto-generated keys, which will be logged at debug level.
setLastReleasedSequenceNumberForGroup(Object, int) - Method in class org.springframework.integration.jdbc.store.JdbcMessageStore
 
setLobHandler(LobHandler) - Method in class org.springframework.integration.jdbc.store.JdbcChannelMessageStore
Override the LobHandler that is used to create and unpack large objects in SQL queries.
setLobHandler(LobHandler) - Method in class org.springframework.integration.jdbc.store.JdbcMessageStore
Override the LobHandler that is used to create and unpack large objects in SQL queries.
setLockHint(String) - Method in class org.springframework.integration.jdbc.metadata.JdbcMetadataStore
Specify a row lock hint for the query in the lock-based operations.
setMaxRows(Integer) - Method in class org.springframework.integration.jdbc.JdbcOutboundGateway
The maximum number of rows to query.
setMaxRows(int) - Method in class org.springframework.integration.jdbc.JdbcPollingChannelAdapter
The maximum number of rows to query.
setMaxRowsPerPoll(Integer) - Method in class org.springframework.integration.jdbc.JdbcOutboundGateway
Deprecated.
setMaxRowsPerPoll(int) - Method in class org.springframework.integration.jdbc.JdbcPollingChannelAdapter
Deprecated.
setMessageGroupFactory(MessageGroupFactory) - Method in class org.springframework.integration.jdbc.store.JdbcChannelMessageStore
Specify the MessageGroupFactory to create MessageGroup object where it is necessary.
setMessageRowMapper(MessageRowMapper) - Method in class org.springframework.integration.jdbc.store.JdbcChannelMessageStore
Allows for passing in a custom MessageRowMapper.
setName(String) - Method in class org.springframework.integration.jdbc.storedproc.ProcedureParameter
 
setParameterExpressions(Map<String, String>) - Method in class org.springframework.integration.jdbc.ExpressionEvaluatingSqlParameterSourceFactory
Optionally maps parameter names to explicit expressions.
setPrefix(String) - Method in class org.springframework.integration.jdbc.lock.DefaultLockRepository
Specify the prefix for target data base table used from queries.
setPreparedStatementSetter(MessagePreparedStatementSetter) - Method in class org.springframework.integration.jdbc.JdbcMessageHandler
Specify a MessagePreparedStatementSetter to populate parameters on the PreparedStatement with the Message context.
setPreparedStatementSetter(ChannelMessageStorePreparedStatementSetter) - Method in class org.springframework.integration.jdbc.store.JdbcChannelMessageStore
Set a ChannelMessageStorePreparedStatementSetter to insert message into the database.
setPriorityEnabled(boolean) - Method in class org.springframework.integration.jdbc.store.JdbcChannelMessageStore
 
setProcedureParameters(List<ProcedureParameter>) - Method in class org.springframework.integration.jdbc.StoredProcExecutor
Custom Stored Procedure parameters that may contain static values or Strings representing an Expression.
setRegion(String) - Method in class org.springframework.integration.jdbc.lock.DefaultLockRepository
A unique grouping identifier for all locks persisted with this store.
setRegion(String) - Method in class org.springframework.integration.jdbc.metadata.JdbcMetadataStore
A unique grouping identifier for all messages persisted with this store.
setRegion(String) - Method in class org.springframework.integration.jdbc.store.JdbcChannelMessageStore
A unique grouping identifier for all messages persisted with this store.
setRegion(String) - Method in class org.springframework.integration.jdbc.store.JdbcMessageStore
A unique grouping identifier for all messages persisted with this store.
setReplySqlParameterSourceFactory(SqlParameterSourceFactory) - Method in class org.springframework.integration.jdbc.JdbcOutboundGateway
 
setRequestPreparedStatementSetter(MessagePreparedStatementSetter) - Method in class org.springframework.integration.jdbc.JdbcOutboundGateway
 
setRequestSqlParameterSourceFactory(SqlParameterSourceFactory) - Method in class org.springframework.integration.jdbc.JdbcOutboundGateway
 
setRequiresReply(boolean) - Method in class org.springframework.integration.jdbc.StoredProcOutboundGateway
 
setReturningResultSetRowMappers(Map<String, RowMapper<?>>) - Method in class org.springframework.integration.jdbc.StoredProcExecutor
If the Stored Procedure returns ResultSets you may provide a map of RowMapper to convert the ResultSet to meaningful objects.
setReturnValueRequired(boolean) - Method in class org.springframework.integration.jdbc.StoredProcExecutor
Indicates the procedure's return value should be included in the results returned.
setRowMapper(RowMapper<?>) - Method in class org.springframework.integration.jdbc.JdbcOutboundGateway
 
setRowMapper(RowMapper<?>) - Method in class org.springframework.integration.jdbc.JdbcPollingChannelAdapter
 
setSelectSqlParameterSource(SqlParameterSource) - Method in class org.springframework.integration.jdbc.JdbcPollingChannelAdapter
A source of parameters for the select query used for polling.
setSerializer(Serializer<? super Message<?>>) - Method in class org.springframework.integration.jdbc.store.JdbcChannelMessageStore
A converter for serializing messages to byte arrays for storage.
setSerializer(Serializer<? super Message<?>>) - Method in class org.springframework.integration.jdbc.store.JdbcMessageStore
A converter for serializing messages to byte arrays for storage.
setSkipUndeclaredResults(boolean) - Method in class org.springframework.integration.jdbc.StoredProcExecutor
If this variable is set to true then all results from a stored procedure call that don't have a corresponding SqlOutParameter declaration will be bypassed.
setSqlParameters(List<SqlParameter>) - Method in class org.springframework.integration.jdbc.StoredProcExecutor
If you database system is not fully supported by Spring and thus obtaining parameter definitions from the JDBC Meta-data is not possible, you must define the SqlParameter explicitly.
setSqlParameterSourceFactory(SqlParameterSourceFactory) - Method in class org.springframework.integration.jdbc.JdbcMessageHandler
 
setSqlParameterSourceFactory(SqlParameterSourceFactory) - Method in class org.springframework.integration.jdbc.StoredProcExecutor
Provides the ability to set a custom SqlParameterSourceFactory.
setSqlParameterTypes(Map<String, Integer>) - Method in class org.springframework.integration.jdbc.ExpressionEvaluatingSqlParameterSourceFactory
Specify sql types for the parameters.
setStaticParameters(Map<String, Object>) - Method in class org.springframework.integration.jdbc.BeanPropertySqlParameterSourceFactory
If the input is a List or a Map, the output is a map parameter source, and in that case some static parameters can be added (default is empty).
setStaticParameters(Map<String, ?>) - Method in class org.springframework.integration.jdbc.ExpressionEvaluatingSqlParameterSourceFactory
Define some static parameter values.
setStoredProcedureName(String) - Method in class org.springframework.integration.jdbc.StoredProcExecutor
The name of the Stored Procedure or Stored Function to be executed.
setStoredProcedureNameExpression(Expression) - Method in class org.springframework.integration.jdbc.StoredProcExecutor
Using the StoredProcExecutor.storedProcedureNameExpression the Message can be used as source for the name of the Stored Procedure or Stored Function.
setTablePrefix(String) - Method in class org.springframework.integration.jdbc.metadata.JdbcMetadataStore
Public setter for the table prefix property.
setTablePrefix(String) - Method in class org.springframework.integration.jdbc.store.JdbcChannelMessageStore
Public setter for the table prefix property.
setTablePrefix(String) - Method in class org.springframework.integration.jdbc.store.JdbcMessageStore
Public setter for the table prefix property.
setTimeToLive(int) - Method in class org.springframework.integration.jdbc.lock.DefaultLockRepository
Specify the time (in milliseconds) to expire dead locks.
setUpdatePerRow(boolean) - Method in class org.springframework.integration.jdbc.JdbcPollingChannelAdapter
 
setUpdateSql(String) - Method in class org.springframework.integration.jdbc.JdbcMessageHandler
Configure an SQL statement to perform an UPDATE on the target database.
setUpdateSql(String) - Method in class org.springframework.integration.jdbc.JdbcPollingChannelAdapter
 
setUpdateSqlParameterSourceFactory(SqlParameterSourceFactory) - Method in class org.springframework.integration.jdbc.JdbcPollingChannelAdapter
 
setUsePayloadAsParameterSource(boolean) - Method in class org.springframework.integration.jdbc.StoredProcExecutor
If set to 'true', the payload of the Message will be used as a source for providing parameters.
setUsingIdCache(boolean) - Method in class org.springframework.integration.jdbc.store.JdbcChannelMessageStore
Consider using this property when polling the database transactionally using multiple parallel threads, meaning when the configured poller is configured using a task executor.
setValue(Object) - Method in class org.springframework.integration.jdbc.storedproc.ProcedureParameter
 
setValues(PreparedStatement, Message<?>) - Method in interface org.springframework.integration.jdbc.MessagePreparedStatementSetter
 
setValues(PreparedStatement, Message<?>, Object, String, boolean) - Method in class org.springframework.integration.jdbc.store.channel.ChannelMessageStorePreparedStatementSetter
Perform a preparedStatement parameters population according provided arguments.
shouldGenerateId() - Method in class org.springframework.integration.jdbc.config.JdbcMessageHandlerParser
 
shouldGenerateId() - Method in class org.springframework.integration.jdbc.config.JdbcPollingChannelAdapterParser
 
shouldGenerateId() - Method in class org.springframework.integration.jdbc.config.StoredProcMessageHandlerParser
 
shouldGenerateId() - Method in class org.springframework.integration.jdbc.config.StoredProcPollingChannelAdapterParser
 
shouldGenerateIdAsFallback() - Method in class org.springframework.integration.jdbc.config.JdbcMessageHandlerParser
 
shouldGenerateIdAsFallback() - Method in class org.springframework.integration.jdbc.config.JdbcPollingChannelAdapterParser
 
shouldGenerateIdAsFallback() - Method in class org.springframework.integration.jdbc.config.StoredProcMessageHandlerParser
 
shouldGenerateIdAsFallback() - Method in class org.springframework.integration.jdbc.config.StoredProcPollingChannelAdapterParser
 
SqlParameterSourceFactory - Interface in org.springframework.integration.jdbc
Collaborator for JDBC adapters which allows creation of instances of SqlParameterSource for use in update operations.
SqlServerChannelMessageStoreQueryProvider - Class in org.springframework.integration.jdbc.store.channel
Channel message store query provider for Microsoft SQL Server / Azure SQL database.
SqlServerChannelMessageStoreQueryProvider() - Constructor for class org.springframework.integration.jdbc.store.channel.SqlServerChannelMessageStoreQueryProvider
 
StoredProcExecutor - Class in org.springframework.integration.jdbc
This class is used by all Stored Procedure (Stored Function) components and provides the core functionality to execute those.
StoredProcExecutor(DataSource) - Constructor for class org.springframework.integration.jdbc.StoredProcExecutor
Constructor taking DataSource from which the DB Connection can be obtained.
StoredProcMessageHandler - Class in org.springframework.integration.jdbc
A message handler that executes Stored Procedures for update purposes.
StoredProcMessageHandler(StoredProcExecutor) - Constructor for class org.springframework.integration.jdbc.StoredProcMessageHandler
Constructor passing in the StoredProcExecutor.
StoredProcMessageHandlerParser - Class in org.springframework.integration.jdbc.config
 
StoredProcMessageHandlerParser() - Constructor for class org.springframework.integration.jdbc.config.StoredProcMessageHandlerParser
 
StoredProcOutboundGateway - Class in org.springframework.integration.jdbc
An AbstractReplyProducingMessageHandler implementation for performing RDBMS stored procedures which return results.
StoredProcOutboundGateway(StoredProcExecutor) - Constructor for class org.springframework.integration.jdbc.StoredProcOutboundGateway
Constructor taking StoredProcExecutor.
StoredProcOutboundGatewayParser - Class in org.springframework.integration.jdbc.config
 
StoredProcOutboundGatewayParser() - Constructor for class org.springframework.integration.jdbc.config.StoredProcOutboundGatewayParser
 
StoredProcParserUtils - Class in org.springframework.integration.jdbc.config
 
StoredProcPollingChannelAdapter - Class in org.springframework.integration.jdbc
A polling channel adapter that creates messages from the payload returned by executing a stored procedure or Sql function.
StoredProcPollingChannelAdapter(StoredProcExecutor) - Constructor for class org.springframework.integration.jdbc.StoredProcPollingChannelAdapter
Constructor taking StoredProcExecutor.
StoredProcPollingChannelAdapterParser - Class in org.springframework.integration.jdbc.config
 
StoredProcPollingChannelAdapterParser() - Constructor for class org.springframework.integration.jdbc.config.StoredProcPollingChannelAdapterParser
 

T

toString() - Method in class org.springframework.integration.jdbc.storedproc.ProcedureParameter
 

V

valueOf(String) - Static method in enum org.springframework.integration.jdbc.config.JdbcTypesEnum
Returns the enum constant of this type with the specified name.
values() - Static method in enum org.springframework.integration.jdbc.config.JdbcTypesEnum
Returns an array containing the constants of this enum type, in the order they are declared.
A B C D E G H I J L M O P R S T V 
Skip navigation links