Package org.springframework.integration.jdbc.store.channel

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

Author:

Sundara Balaji

Constructor Summary

Constructors

Constructor	Description
SqlServerChannelMessageStoreQueryProvider()

Method Summary

Modifier and Type	Method	Description
String	getCreateMessageQuery()	Query to add a single message to the database.
String	getPollFromGroupExcludeIdsQuery()	Get the query used to retrieve the oldest message for a channel excluding messages that match the provided message ids.
String	getPollFromGroupQuery()	Get the query used to retrieve the oldest message for a channel.
String	getPriorityPollFromGroupExcludeIdsQuery()	Get the query used to retrieve the oldest message by priority for a channel excluding messages that match the provided message ids.
String	getPriorityPollFromGroupQuery()	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

Methods inherited from class java.lang.Object

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

Constructor Details

SqlServerChannelMessageStoreQueryProvider

public SqlServerChannelMessageStoreQueryProvider()

Method Details

getPollFromGroupExcludeIdsQuery

public String 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.

Returns:

Sql Query

getPollFromGroupQuery

public String getPollFromGroupQuery()

Description copied from interface: ChannelMessageStoreQueryProvider

Get the query used to retrieve the oldest message for a channel.

Returns:

Sql Query

getPriorityPollFromGroupExcludeIdsQuery

public 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.

Returns:

Sql Query

getPriorityPollFromGroupQuery

public String getPriorityPollFromGroupQuery()

Description copied from interface: ChannelMessageStoreQueryProvider

Get the query used to retrieve the oldest message by priority for a channel.

Returns:

Sql Query

getCreateMessageQuery

public String getCreateMessageQuery()

Description copied from interface: ChannelMessageStoreQueryProvider

Query to add a single message to the database.

Specified by:

getCreateMessageQuery in interface ChannelMessageStoreQueryProvider

Overrides:

getCreateMessageQuery in class AbstractChannelMessageStoreQueryProvider

Returns:

Sql Query