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

Class H2ChannelMessageStoreQueryProvider

java.lang.Object

org.springframework.integration.jdbc.store.channel.AbstractChannelMessageStoreQueryProvider

org.springframework.integration.jdbc.store.channel.H2ChannelMessageStoreQueryProvider

All Implemented Interfaces:

ChannelMessageStoreQueryProvider

public class H2ChannelMessageStoreQueryProvider
extends AbstractChannelMessageStoreQueryProvider

Since:

4.3

Author:

Gunnar Hillert, Artem Bilan, Manuel Jordan, Gary Russell

Constructor Summary

Constructors

Constructor	Description
H2ChannelMessageStoreQueryProvider()

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

H2ChannelMessageStoreQueryProvider

public H2ChannelMessageStoreQueryProvider()

Method Details

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

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