Class SqlServerChannelMessageStoreQueryProvider
java.lang.Object
org.springframework.integration.jdbc.store.channel.SqlServerChannelMessageStoreQueryProvider
- All Implemented Interfaces:
ChannelMessageStoreQueryProvider
public class SqlServerChannelMessageStoreQueryProvider
extends Object
implements ChannelMessageStoreQueryProvider
Channel message store query provider for Microsoft SQL Server / Azure SQL database.
- Since:
- 5.1
- Author:
- Sundara Balaji, Adama Sorho, Artem Bilan
-
Field Summary
Fields inherited from interface org.springframework.integration.jdbc.store.channel.ChannelMessageStoreQueryProvider
SELECT_COMMON
-
Constructor Summary
-
Method Summary
Modifier and TypeMethodDescriptionQuery to add a single message to the database.Get the query used to retrieve the oldest message for a channel excluding messages that match the provided message ids.Get the query used to retrieve the oldest message for a channel.Get the query used to retrieve the oldest message by priority for a channel excluding messages that match the provided message ids.Get the query used to retrieve the oldest message by priority for a channel.Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
Methods inherited from interface org.springframework.integration.jdbc.store.channel.ChannelMessageStoreQueryProvider
getCountAllMessagesInGroupQuery, getDeleteMessageGroupQuery, getDeleteMessageQuery, getMessageCountForRegionQuery, getMessageQuery, isSingleStatementForPoll
-
Constructor Details
-
SqlServerChannelMessageStoreQueryProvider
public SqlServerChannelMessageStoreQueryProvider()
-
-
Method Details
-
getPollFromGroupExcludeIdsQuery
Description copied from interface:ChannelMessageStoreQueryProvider
Get the query used to retrieve the oldest message for a channel excluding messages that match the provided message ids.- Specified by:
getPollFromGroupExcludeIdsQuery
in interfaceChannelMessageStoreQueryProvider
- Returns:
- query string
-
getPollFromGroupQuery
Description copied from interface:ChannelMessageStoreQueryProvider
Get the query used to retrieve the oldest message for a channel.- Specified by:
getPollFromGroupQuery
in interfaceChannelMessageStoreQueryProvider
- Returns:
- query string
-
getPriorityPollFromGroupExcludeIdsQuery
Description copied from interface:ChannelMessageStoreQueryProvider
Get the query used to retrieve the oldest message by priority for a channel excluding messages that match the provided message ids.- Specified by:
getPriorityPollFromGroupExcludeIdsQuery
in interfaceChannelMessageStoreQueryProvider
- Returns:
- query string
-
getPriorityPollFromGroupQuery
Description copied from interface:ChannelMessageStoreQueryProvider
Get the query used to retrieve the oldest message by priority for a channel.- Specified by:
getPriorityPollFromGroupQuery
in interfaceChannelMessageStoreQueryProvider
- Returns:
- query string
-
getCreateMessageQuery
Description copied from interface:ChannelMessageStoreQueryProvider
Query to add a single message to the database.- Specified by:
getCreateMessageQuery
in interfaceChannelMessageStoreQueryProvider
- Returns:
- query string
-