Class PostgresChannelMessageStoreQueryProvider

java.lang.Object

org.springframework.integration.jdbc.store.channel.PostgresChannelMessageStoreQueryProvider

All Implemented Interfaces:

ChannelMessageStoreQueryProvider

public class PostgresChannelMessageStoreQueryProvider
extends Object
implements ChannelMessageStoreQueryProvider

Since:

2.2

Author:

Gunnar Hillert, Artem Bilan, Adama Sorho, Johannes Edmeier

Field Summary

Fields inherited from interface org.springframework.integration.jdbc.store.channel.ChannelMessageStoreQueryProvider

SELECT_COMMON

Constructor Summary

Constructors

Constructor	Description
PostgresChannelMessageStoreQueryProvider()

Method Summary

Modifier and Type	Method	Description
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.
boolean	isSingleStatementForPoll()	Indicate if the queries for polling are using a single statement (e.g.

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, getCreateMessageQuery, getDeleteMessageGroupQuery, getDeleteMessageQuery, getMessageCountForRegionQuery, getMessageQuery

Constructor Details

PostgresChannelMessageStoreQueryProvider

public PostgresChannelMessageStoreQueryProvider()

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.

Specified by:

getPollFromGroupExcludeIdsQuery in interface ChannelMessageStoreQueryProvider

Returns:

query string

getPollFromGroupQuery

public String getPollFromGroupQuery()

Description copied from interface: ChannelMessageStoreQueryProvider

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

Specified by:

getPollFromGroupQuery in interface ChannelMessageStoreQueryProvider

Returns:

query string

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.

Specified by:

getPriorityPollFromGroupExcludeIdsQuery in interface ChannelMessageStoreQueryProvider

Returns:

query string

getPriorityPollFromGroupQuery

public 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 interface ChannelMessageStoreQueryProvider

Returns:

query string

isSingleStatementForPoll

public boolean isSingleStatementForPoll()

Description copied from interface: ChannelMessageStoreQueryProvider

Indicate if the queries for polling are using a single statement (e.g. DELETE ... RETURNING) to retrieve and delete the message from the channel store.

Specified by:

isSingleStatementForPoll in interface ChannelMessageStoreQueryProvider

Returns:

true if a single statement is used, false if a select and delete is required.