Class SqlServerChannelMessageStoreQueryProvider
java.lang.Object
org.springframework.integration.jdbc.store.channel.AbstractChannelMessageStoreQueryProvider
org.springframework.integration.jdbc.store.channel.SqlServerChannelMessageStoreQueryProvider
- All Implemented Interfaces:
ChannelMessageStoreQueryProvider
public class SqlServerChannelMessageStoreQueryProvider extends AbstractChannelMessageStoreQueryProvider
Channel message store query provider for Microsoft SQL Server / Azure SQL database.
- Since:
- 5.1
-
Constructor Summary
Constructors Constructor Description SqlServerChannelMessageStoreQueryProvider() -
Method Summary
Modifier and Type Method Description java.lang.StringgetCreateMessageQuery()Query to add a single message to the database.java.lang.StringgetPollFromGroupExcludeIdsQuery()Get the query used to retrieve the oldest message for a channel excluding messages that match the provided message ids.java.lang.StringgetPollFromGroupQuery()Get the query used to retrieve the oldest message for a channel.java.lang.StringgetPriorityPollFromGroupExcludeIdsQuery()Get the query used to retrieve the oldest message by priority for a channel excluding messages that match the provided message ids.java.lang.StringgetPriorityPollFromGroupQuery()Get the query used to retrieve the oldest message by priority for a channel.Methods inherited from class org.springframework.integration.jdbc.store.channel.AbstractChannelMessageStoreQueryProvider
getCountAllMessagesInGroupQuery, getDeleteMessageGroupQuery, getDeleteMessageQuery, getMessageCountForRegionQuery, getMessageQuery
-
Constructor Details
-
SqlServerChannelMessageStoreQueryProvider
public SqlServerChannelMessageStoreQueryProvider()
-
-
Method Details
-
getPollFromGroupExcludeIdsQuery
public java.lang.String getPollFromGroupExcludeIdsQuery()Description copied from interface:ChannelMessageStoreQueryProviderGet the query used to retrieve the oldest message for a channel excluding messages that match the provided message ids.- Returns:
- Sql Query
-
getPollFromGroupQuery
public java.lang.String getPollFromGroupQuery()Description copied from interface:ChannelMessageStoreQueryProviderGet the query used to retrieve the oldest message for a channel.- Returns:
- Sql Query
-
getPriorityPollFromGroupExcludeIdsQuery
public java.lang.String getPriorityPollFromGroupExcludeIdsQuery()Description copied from interface:ChannelMessageStoreQueryProviderGet the query used to retrieve the oldest message by priority for a channel excluding messages that match the provided message ids.- Returns:
- Sql Query
-
getPriorityPollFromGroupQuery
public java.lang.String getPriorityPollFromGroupQuery()Description copied from interface:ChannelMessageStoreQueryProviderGet the query used to retrieve the oldest message by priority for a channel.- Returns:
- Sql Query
-
getCreateMessageQuery
public java.lang.String getCreateMessageQuery()Description copied from interface:ChannelMessageStoreQueryProviderQuery to add a single message to the database.- Specified by:
getCreateMessageQueryin interfaceChannelMessageStoreQueryProvider- Overrides:
getCreateMessageQueryin classAbstractChannelMessageStoreQueryProvider- Returns:
- Sql Query
-