Index
All Classes and Interfaces|All Packages|Constant Field Values
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
-
Acquire a lock for a key.
- addAllowedPatterns(String...) - Method in class org.springframework.integration.jdbc.store.JdbcChannelMessageStore
-
Add patterns for packages/classes that are allowed to be deserialized.
- addAllowedPatterns(String...) - Method in class org.springframework.integration.jdbc.store.JdbcMessageStore
-
Add patterns for packages/classes that are allowed to be deserialized.
- 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.
- 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
-
Check mandatory properties (
DataSourceandJdbcChannelMessageStore.setChannelMessageStoreQueryProvider(ChannelMessageStoreQueryProvider)). - afterPropertiesSet() - Method in class org.springframework.integration.jdbc.StoredProcExecutor
-
Verifies parameters, sets the parameters on
SimpleJdbcCallOperationsand ensures the appropriateSqlParameterSourceFactoryis defined whenProcedureParameterare passed in. - afterSingletonsInstantiated() - Method in class org.springframework.integration.jdbc.lock.DefaultLockRepository
- ARRAY - Enum constant in enum class org.springframework.integration.jdbc.config.JdbcTypesEnum
B
- BeanPropertySqlParameterSourceFactory - Class in org.springframework.integration.jdbc
-
A default implementation of
SqlParameterSourceFactorywhich creates anSqlParameterSourceto reference bean properties in its input. - BeanPropertySqlParameterSourceFactory() - Constructor for class org.springframework.integration.jdbc.BeanPropertySqlParameterSourceFactory
- BIGINT - Enum constant in enum class org.springframework.integration.jdbc.config.JdbcTypesEnum
- BINARY - Enum constant in enum class org.springframework.integration.jdbc.config.JdbcTypesEnum
- BIT - Enum constant in enum class org.springframework.integration.jdbc.config.JdbcTypesEnum
- BLOB - Enum constant in enum class org.springframework.integration.jdbc.config.JdbcTypesEnum
- BOOLEAN - Enum constant in enum class org.springframework.integration.jdbc.config.JdbcTypesEnum
C
- ChannelMessageStorePreparedStatementSetter - Class in org.springframework.integration.jdbc.store.channel
-
Callback to be used with the
JdbcChannelMessageStore. - 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[]. - ChannelMessageStorePreparedStatementSetter(SerializingConverter, LobHandler) - Constructor for class org.springframework.integration.jdbc.store.channel.ChannelMessageStorePreparedStatementSetter
-
Instantiate a
ChannelMessageStorePreparedStatementSetterwith the provided serializer and lobHandler, which both must not be null. - ChannelMessageStoreQueryProvider - Interface in org.springframework.integration.jdbc.store.channel
-
Common interface used in order to configure the
JdbcChannelMessageStoreto provide database-specific queries. - CHAR - Enum constant in enum class org.springframework.integration.jdbc.config.JdbcTypesEnum
- CLOB - Enum constant in enum class org.springframework.integration.jdbc.config.JdbcTypesEnum
- 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
ProcedureParameterto 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
ProcedureParameterto a Map containing only static parameters. - convertToJdbcTypesEnum(String) - Static method in enum class org.springframework.integration.jdbc.config.JdbcTypesEnum
-
Retrieve the matching enum constant for a provided String representation of the SQL Types.
- 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
SqlParameterSourcethat does not cache it's results.
D
- DATALINK - Enum constant in enum class org.springframework.integration.jdbc.config.JdbcTypesEnum
- DATE - Enum constant in enum class org.springframework.integration.jdbc.config.JdbcTypesEnum
- DECIMAL - Enum constant in enum class org.springframework.integration.jdbc.config.JdbcTypesEnum
- 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
LockRepositorybased on the table from the script presented in theorg/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
-
Remove a lock from this repository.
- deleteExpired() - Method in class org.springframework.integration.jdbc.lock.DefaultLockRepository
- deleteExpired() - Method in interface org.springframework.integration.jdbc.lock.LockRepository
-
Remove all the expired locks.
- DerbyChannelMessageStoreQueryProvider - Class in org.springframework.integration.jdbc.store.channel
- DerbyChannelMessageStoreQueryProvider() - Constructor for class org.springframework.integration.jdbc.store.channel.DerbyChannelMessageStoreQueryProvider
- DISTINCT - Enum constant in enum class org.springframework.integration.jdbc.config.JdbcTypesEnum
- 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
-
Perform a select against provided
SqlParameterSource. - 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
JdbcChannelMessageStoremeans 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.
- doSend(Message<?>, long) - Method in class org.springframework.integration.jdbc.channel.PostgresSubscribableChannel
- DOUBLE - Enum constant in enum class org.springframework.integration.jdbc.config.JdbcTypesEnum
E
- executeStoredProcedure() - Method in class org.springframework.integration.jdbc.StoredProcExecutor
-
Execute a Stored Procedure or Function - Use when no
Messageis available to extractProcedureParametervalues from it. - executeStoredProcedure(Message<?>) - Method in class org.springframework.integration.jdbc.StoredProcExecutor
-
Execute a Stored Procedure or Function - Use with
Messageis available to extractProcedureParametervalues from it. - executeUpdateQuery(Message<?>, boolean) - Method in class org.springframework.integration.jdbc.JdbcMessageHandler
-
Execute an update for the provided message and generated keys flag.
- expireUnusedOlderThan(long) - Method in class org.springframework.integration.jdbc.lock.JdbcLockRegistry
- ExpressionEvaluatingSqlParameterSourceFactory - Class in org.springframework.integration.jdbc
-
An implementation of
SqlParameterSourceFactorywhich creates anSqlParameterSourcethat evaluates Spring EL expressions. - ExpressionEvaluatingSqlParameterSourceFactory() - Constructor for class org.springframework.integration.jdbc.ExpressionEvaluatingSqlParameterSourceFactory
F
- FLOAT - Enum constant in enum class org.springframework.integration.jdbc.config.JdbcTypesEnum
G
- get() - Method in interface org.springframework.integration.jdbc.channel.PgConnectionSupplier
-
Supply an open, un-pooled connection to a Postgres database.
- get(String) - Method in class org.springframework.integration.jdbc.metadata.JdbcMetadataStore
- getCode() - Method in enum class 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.
- getDispatcher() - Method in class org.springframework.integration.jdbc.channel.PostgresSubscribableChannel
- getExpression() - Method in class org.springframework.integration.jdbc.storedproc.ProcedureParameter
- getGroupId() - Method in interface org.springframework.integration.jdbc.channel.PostgresChannelMessageTableSubscriber.Subscription
-
Return the group id for which this subscription receives notifications.
- getGroupId() - Method in class org.springframework.integration.jdbc.channel.PostgresSubscribableChannel
- getGroupMetadata(Object) - Method in class org.springframework.integration.jdbc.store.JdbcMessageStore
- getInputChannelAttributeName() - Method in class org.springframework.integration.jdbc.config.JdbcOutboundGatewayParser
- getInputChannelAttributeName() - Method in class org.springframework.integration.jdbc.config.StoredProcOutboundGatewayParser
- 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
-
Return the number of message groups in the store for configured region.
- getMessageGroupCount() - Method in class org.springframework.integration.jdbc.store.JdbcMessageStore
- getMessageGroupFactory() - Method in class org.springframework.integration.jdbc.store.JdbcChannelMessageStore
-
Return the
MessageGroupFactory. - 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(JdbcChannelMessageStore.Query, Supplier<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.
- getRegion() - Method in interface org.springframework.integration.jdbc.channel.PostgresChannelMessageTableSubscriber.Subscription
-
Return the region for which this subscription receives notifications.
- getRegion() - Method in class org.springframework.integration.jdbc.channel.PostgresSubscribableChannel
- getRegion() - Method in class org.springframework.integration.jdbc.store.JdbcChannelMessageStore
-
Returns the current region that was set or
JdbcChannelMessageStore.DEFAULT_REGION, which is the default. - getReturningResultsetBeanDefinitions(Element, ParserContext) - Static method in class org.springframework.integration.jdbc.config.StoredProcParserUtils
- getSizeOfIdCache() - Method in class org.springframework.integration.jdbc.store.JdbcChannelMessageStore
-
Return 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
BeanDefinitionBuilderfor the classStoredProcExecutor. - 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
- INTEGER - Enum constant in enum class org.springframework.integration.jdbc.config.JdbcTypesEnum
- isAcquired(String) - Method in class org.springframework.integration.jdbc.lock.DefaultLockRepository
- isAcquired(String) - Method in interface org.springframework.integration.jdbc.lock.LockRepository
-
Check if a lock is held by this repository.
- isPriorityEnabled() - Method in class org.springframework.integration.jdbc.store.JdbcChannelMessageStore
- isRunning() - Method in class org.springframework.integration.jdbc.channel.PostgresChannelMessageTableSubscriber
- iterator() - Method in class org.springframework.integration.jdbc.store.JdbcMessageStore
J
- JAVA_OBJECT - Enum constant in enum class org.springframework.integration.jdbc.config.JdbcTypesEnum
- JdbcChannelMessageStore - Class in org.springframework.integration.jdbc.store
-
Channel-specific implementation of
BasicMessageGroupStoreusing 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
MessageStorewith all mandatory properties. - JdbcLockRegistry - Class in org.springframework.integration.jdbc.lock
-
An
ExpirableLockRegistryusing a shared database to co-ordinate the locks. - JdbcLockRegistry(LockRepository) - Constructor for class org.springframework.integration.jdbc.lock.JdbcLockRegistry
-
Construct an instance based on the provided
LockRepository. - 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
DataSourcefrom 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
JdbcOperationsinstance 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
MessageStoreusing a relational database via JDBC. - JdbcMessageStore(DataSource) - Constructor for class org.springframework.integration.jdbc.store.JdbcMessageStore
-
Create a
MessageStorewith all mandatory properties. - JdbcMessageStore(JdbcOperations) - Constructor for class org.springframework.integration.jdbc.store.JdbcMessageStore
-
Create a
MessageStorewith 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
ConcurrentMetadataStoreusing a relational database via JDBC. - JdbcMetadataStore(DataSource) - Constructor for class org.springframework.integration.jdbc.metadata.JdbcMetadataStore
-
Instantiate a
JdbcMetadataStoreusing provided dataSourceDataSource. - JdbcMetadataStore(JdbcOperations) - Constructor for class org.springframework.integration.jdbc.metadata.JdbcMetadataStore
-
Instantiate a
JdbcMetadataStoreusing provided jdbcOperationsJdbcOperations. - 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
-
Construct an instance based on the provided
DataSourceand update SQL. - JdbcOutboundGateway(DataSource, String, String) - Constructor for class org.springframework.integration.jdbc.JdbcOutboundGateway
-
Construct an instance based on the provided
DataSource, select and update SQLs. - JdbcOutboundGateway(JdbcOperations, String) - Constructor for class org.springframework.integration.jdbc.JdbcOutboundGateway
-
Construct an instance based on the provided
JdbcOperationsand update SQL. - JdbcOutboundGateway(JdbcOperations, String, String) - Constructor for class org.springframework.integration.jdbc.JdbcOutboundGateway
-
Construct an instance based on the provided
JdbcOperations, select and update SQLs. - 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
DataSourcefrom 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
JdbcOperationsinstance to use for query execution and the select query to execute to retrieve new rows. - JdbcPollingChannelAdapterParser - Class in org.springframework.integration.jdbc.config
-
Parser for
JdbcPollingChannelAdapter. - JdbcPollingChannelAdapterParser() - Constructor for class org.springframework.integration.jdbc.config.JdbcPollingChannelAdapterParser
- JdbcTypesEnum - Enum Class 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.
- LONGNVARCHAR - Enum constant in enum class org.springframework.integration.jdbc.config.JdbcTypesEnum
- LONGVARBINARY - Enum constant in enum class org.springframework.integration.jdbc.config.JdbcTypesEnum
- LONGVARCHAR - Enum constant in enum class org.springframework.integration.jdbc.config.JdbcTypesEnum
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
-
Return 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
JdbcMessageHandleras an alternative to theSqlParameterSourceFactory. - MessageRowMapper - Class in org.springframework.integration.jdbc.store.channel
-
Convenience class to be used to unpack a
Messagefrom a result set row. - MessageRowMapper(AllowListDeserializingConverter, LobHandler) - Constructor for class org.springframework.integration.jdbc.store.channel.MessageRowMapper
-
Construct an instance based on the provided
AllowListDeserializingConverterandLobHandler. - MySqlChannelMessageStoreQueryProvider - Class in org.springframework.integration.jdbc.store.channel
- MySqlChannelMessageStoreQueryProvider() - Constructor for class org.springframework.integration.jdbc.store.channel.MySqlChannelMessageStoreQueryProvider
N
- NCHAR - Enum constant in enum class org.springframework.integration.jdbc.config.JdbcTypesEnum
- NCLOB - Enum constant in enum class org.springframework.integration.jdbc.config.JdbcTypesEnum
- notifyUpdate() - Method in interface org.springframework.integration.jdbc.channel.PostgresChannelMessageTableSubscriber.Subscription
-
Indicate that a message was added to the represented region and group id.
- notifyUpdate() - Method in class org.springframework.integration.jdbc.channel.PostgresSubscribableChannel
- NULL - Enum constant in enum class org.springframework.integration.jdbc.config.JdbcTypesEnum
- NUMERIC - Enum constant in enum class org.springframework.integration.jdbc.config.JdbcTypesEnum
- NVARCHAR - Enum constant in enum class org.springframework.integration.jdbc.config.JdbcTypesEnum
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.channel - package org.springframework.integration.jdbc.channel
-
Provides a message channel-specific JDBC API.
- 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.
- OTHER - Enum constant in enum class org.springframework.integration.jdbc.config.JdbcTypesEnum
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
- PgConnectionSupplier - Interface in org.springframework.integration.jdbc.channel
-
A connection supplier for a
PgConnectionto a Postgres database that is to be used for aPostgresChannelMessageTableSubscriber. - pollMessageFromGroup(Object) - Method in class org.springframework.integration.jdbc.store.JdbcChannelMessageStore
-
Poll 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
- PostgresChannelMessageTableSubscriber - Class in org.springframework.integration.jdbc.channel
-
A subscriber for new messages being received by a Postgres database via a
JdbcChannelMessageStore. - PostgresChannelMessageTableSubscriber(PgConnectionSupplier) - Constructor for class org.springframework.integration.jdbc.channel.PostgresChannelMessageTableSubscriber
-
Create a new subscriber using the
JdbcChannelMessageStore.DEFAULT_TABLE_PREFIX. - PostgresChannelMessageTableSubscriber(PgConnectionSupplier, String) - Constructor for class org.springframework.integration.jdbc.channel.PostgresChannelMessageTableSubscriber
-
Create a new subscriber.
- PostgresChannelMessageTableSubscriber.Subscription - Interface in org.springframework.integration.jdbc.channel
-
A subscription to a
PostgresChannelMessageTableSubscriberfor receiving push notifications for new messages that are added to aJdbcChannelMessageStore. - PostgresSubscribableChannel - Class in org.springframework.integration.jdbc.channel
-
An
AbstractSubscribableChannelfor receiving push notifications for messages send to a group id of aJdbcChannelMessageStore. - PostgresSubscribableChannel(JdbcChannelMessageStore, Object, PostgresChannelMessageTableSubscriber) - Constructor for class org.springframework.integration.jdbc.channel.PostgresSubscribableChannel
-
Create a subscribable channel for a Postgres database.
- ProcedureParameter - Class in org.springframework.integration.jdbc.storedproc
-
Abstraction of Procedure parameters allowing to provide static parameters and SpEl Expression based parameters.
- ProcedureParameter() - Constructor for class org.springframework.integration.jdbc.storedproc.ProcedureParameter
-
Default constructor.
- ProcedureParameter(String, Object, String) - Constructor for class org.springframework.integration.jdbc.storedproc.ProcedureParameter
-
Instantiates a new Procedure Parameter.
- 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
- REAL - Enum constant in enum class org.springframework.integration.jdbc.config.JdbcTypesEnum
- REF - Enum constant in enum class org.springframework.integration.jdbc.config.JdbcTypesEnum
- 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
- renew(String) - Method in class org.springframework.integration.jdbc.lock.DefaultLockRepository
- renew(String) - Method in interface org.springframework.integration.jdbc.lock.LockRepository
-
Renew the lease for a lock.
- renewLock(Object) - Method in class org.springframework.integration.jdbc.lock.JdbcLockRegistry
- replace(String, String, String) - Method in class org.springframework.integration.jdbc.metadata.JdbcMetadataStore
- ROWID - Enum constant in enum class org.springframework.integration.jdbc.config.JdbcTypesEnum
S
- setApplicationContext(ApplicationContext) - Method in class org.springframework.integration.jdbc.lock.DefaultLockRepository
- setBeanClassLoader(ClassLoader) - Method in class org.springframework.integration.jdbc.store.JdbcMessageStore
- setBeanFactory(BeanFactory) - Method in class org.springframework.integration.jdbc.StoredProcExecutor
-
Allows to set the optional
BeanFactorywhich is used to add aBeanResolverto theStandardEvaluationContext. - setCacheCapacity(int) - Method in class org.springframework.integration.jdbc.lock.JdbcLockRegistry
-
Set the capacity of cached locks.
- setChannelMessageStoreQueryProvider(ChannelMessageStoreQueryProvider) - Method in class org.springframework.integration.jdbc.store.JdbcChannelMessageStore
-
Set the database specific
ChannelMessageStoreQueryProviderto use. - setDataSource(DataSource) - Method in class org.springframework.integration.jdbc.store.JdbcChannelMessageStore
-
The JDBC
DataSourceto 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 message.
- setDispatcherExecutor(Executor) - Method in class org.springframework.integration.jdbc.channel.PostgresSubscribableChannel
-
Set the executor to use for dispatching newly received messages.
- setExecutor(ExecutorService) - Method in class org.springframework.integration.jdbc.channel.PostgresChannelMessageTableSubscriber
-
Define an executor to use for listening for new 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
- setGroupCondition(Object, String) - Method in class org.springframework.integration.jdbc.store.JdbcMessageStore
- setIdleBetweenTries(Duration) - Method in class org.springframework.integration.jdbc.lock.JdbcLockRegistry
-
Specify a @link Duration} to sleep between lock record insert/update attempts.
- setIgnoreColumnMetaData(boolean) - Method in class org.springframework.integration.jdbc.StoredProcExecutor
-
For fully supported databases, the underlying
SimpleJdbcCallcan 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
SimpleJdbcCallOperationsA value of zero will disable the cache. - setJdbcTemplate(JdbcTemplate) - Method in class org.springframework.integration.jdbc.store.JdbcChannelMessageStore
-
The
JdbcOperationsto 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
LobHandlerthat is used to create and unpack large objects in SQL queries. - setLobHandler(LobHandler) - Method in class org.springframework.integration.jdbc.store.JdbcMessageStore
-
Override the
LobHandlerthat 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(int) - Method in class org.springframework.integration.jdbc.JdbcPollingChannelAdapter
-
The maximum number of rows to query.
- setMaxRows(Integer) - Method in class org.springframework.integration.jdbc.JdbcOutboundGateway
-
The maximum number of rows to query.
- setMessageGroupFactory(MessageGroupFactory) - Method in class org.springframework.integration.jdbc.store.JdbcChannelMessageStore
-
Specify the
MessageGroupFactoryto createMessageGroupobject where it is necessary. - setMessageRowMapper(MessageRowMapper) - Method in class org.springframework.integration.jdbc.store.JdbcChannelMessageStore
-
Allow 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 database table used from queries.
- setPreparedStatementSetter(MessagePreparedStatementSetter) - Method in class org.springframework.integration.jdbc.JdbcMessageHandler
-
Specify a
MessagePreparedStatementSetterto populate parameters on thePreparedStatementwith theMessagecontext. - setPreparedStatementSetter(ChannelMessageStorePreparedStatementSetter) - Method in class org.springframework.integration.jdbc.store.JdbcChannelMessageStore
-
Set a
ChannelMessageStorePreparedStatementSetterto insert message into the database. - setPriorityEnabled(boolean) - Method in class org.springframework.integration.jdbc.store.JdbcChannelMessageStore
-
Enable a priority handling in this store.
- 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
-
/** Set a
SqlParameterSourceFactoryfor select query. - setRequestPreparedStatementSetter(MessagePreparedStatementSetter) - Method in class org.springframework.integration.jdbc.JdbcOutboundGateway
-
Set a
MessagePreparedStatementSetterfor update query. - setRequestSqlParameterSourceFactory(SqlParameterSourceFactory) - Method in class org.springframework.integration.jdbc.JdbcOutboundGateway
-
Set a
SqlParameterSourceFactoryfor update query. - 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
RowMapperto convert theResultSetto 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
-
Set a select result
RowMapper. - setRowMapper(RowMapper<?>) - Method in class org.springframework.integration.jdbc.JdbcPollingChannelAdapter
-
Set a
RowMapper. - setSelectQuery(String) - Method in class org.springframework.integration.jdbc.JdbcPollingChannelAdapter
-
Set the select query.
- 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
truethen all results from a stored procedure call that don't have a correspondingSqlOutParameterdeclaration 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
SqlParameterexplicitly. - setSqlParameterSourceFactory(SqlParameterSourceFactory) - Method in class org.springframework.integration.jdbc.JdbcMessageHandler
-
Configure an
SqlParameterSourceFactory. - 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, Object>) - 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.storedProcedureNameExpressiontheMessagecan 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.
- setTransactionManager(PlatformTransactionManager) - Method in class org.springframework.integration.jdbc.lock.DefaultLockRepository
-
Set a
PlatformTransactionManagerfor operations. - setUpdatePerRow(boolean) - Method in class org.springframework.integration.jdbc.JdbcPollingChannelAdapter
-
Set a flag to update per record or not.
- setUpdateSql(String) - Method in class org.springframework.integration.jdbc.JdbcPollingChannelAdapter
-
Set an update query.
- setUpdateSqlParameterSourceFactory(SqlParameterSourceFactory) - Method in class org.springframework.integration.jdbc.JdbcPollingChannelAdapter
-
Set an
SqlParameterSourceFactoryfor update query. - 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
-
Set parameter values on the given
PreparedStatementand message context. - 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
- SMALLINT - Enum constant in enum class org.springframework.integration.jdbc.config.JdbcTypesEnum
- SqlParameterSourceFactory - Interface in org.springframework.integration.jdbc
-
Collaborator for JDBC adapters which allows creation of instances of
SqlParameterSourcefor 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
- SQLXML - Enum constant in enum class org.springframework.integration.jdbc.config.JdbcTypesEnum
- start() - Method in class org.springframework.integration.jdbc.channel.PostgresChannelMessageTableSubscriber
- stop() - Method in class org.springframework.integration.jdbc.channel.PostgresChannelMessageTableSubscriber
- 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
DataSourcefrom 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
AbstractReplyProducingMessageHandlerimplementation 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
- streamMessagesForGroup(Object) - Method in class org.springframework.integration.jdbc.store.JdbcMessageStore
- STRUCT - Enum constant in enum class org.springframework.integration.jdbc.config.JdbcTypesEnum
- subscribe(PostgresChannelMessageTableSubscriber.Subscription) - Method in class org.springframework.integration.jdbc.channel.PostgresChannelMessageTableSubscriber
-
Add a new subscription to this subscriber.
- subscribe(MessageHandler) - Method in class org.springframework.integration.jdbc.channel.PostgresSubscribableChannel
T
- TIME - Enum constant in enum class org.springframework.integration.jdbc.config.JdbcTypesEnum
- TIMESTAMP - Enum constant in enum class org.springframework.integration.jdbc.config.JdbcTypesEnum
- TINYINT - Enum constant in enum class org.springframework.integration.jdbc.config.JdbcTypesEnum
- toString() - Method in class org.springframework.integration.jdbc.storedproc.ProcedureParameter
U
- unsubscribe(PostgresChannelMessageTableSubscriber.Subscription) - Method in class org.springframework.integration.jdbc.channel.PostgresChannelMessageTableSubscriber
-
Remove a previous subscription from this subscriber.
- unsubscribe(MessageHandler) - Method in class org.springframework.integration.jdbc.channel.PostgresSubscribableChannel
V
- valueOf(String) - Static method in enum class org.springframework.integration.jdbc.config.JdbcTypesEnum
-
Returns the enum constant of this class with the specified name.
- values() - Static method in enum class org.springframework.integration.jdbc.config.JdbcTypesEnum
-
Returns an array containing the constants of this enum class, in the order they are declared.
- VARBINARY - Enum constant in enum class org.springframework.integration.jdbc.config.JdbcTypesEnum
- VARCHAR - Enum constant in enum class org.springframework.integration.jdbc.config.JdbcTypesEnum
All Classes and Interfaces|All Packages|Constant Field Values