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

Class HsqlChannelMessageStoreQueryProvider

java.lang.Object

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

org.springframework.integration.jdbc.store.channel.HsqlChannelMessageStoreQueryProvider

All Implemented Interfaces:

ChannelMessageStoreQueryProvider

public class HsqlChannelMessageStoreQueryProvider
extends AbstractChannelMessageStoreQueryProvider

Since:

2.2

Author:

Gunnar Hillert, Artem Bilan

Constructor Summary

Constructors

Constructor	Description
HsqlChannelMessageStoreQueryProvider()

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

HsqlChannelMessageStoreQueryProvider

public HsqlChannelMessageStoreQueryProvider()

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