org.springframework.integration.jdbc.store.channel

Class MySqlChannelMessageStoreQueryProvider

java.lang.Object

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

org.springframework.integration.jdbc.store.channel.MySqlChannelMessageStoreQueryProvider

All Implemented Interfaces:

ChannelMessageStoreQueryProvider

public class MySqlChannelMessageStoreQueryProvider
extends AbstractChannelMessageStoreQueryProvider

Since:

2.2

Author:

Gunnar Hillert

Constructor Summary

Constructors

Constructor and Description
MySqlChannelMessageStoreQueryProvider()

Method Summary

Methods

Modifier and Type	Method and Description
java.lang.String	getPollFromGroupExcludeIdsQuery() Get the query used to retrieve the oldest message for a channel excluding messages that match the provided message ids.
java.lang.String	getPollFromGroupQuery() Get the query used to retrieve the oldest message for a channel.

Methods inherited from class org.springframework.integration.jdbc.store.channel.AbstractChannelMessageStoreQueryProvider

getCountAllMessagesInGroupQuery, getCreateMessageQuery, getDeleteMessageGroupQuery, getDeleteMessageQuery, getMessageCountForRegionQuery, getMessageQuery

Methods inherited from class java.lang.Object

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

Constructor Detail

MySqlChannelMessageStoreQueryProvider

public MySqlChannelMessageStoreQueryProvider()

Method Detail

getPollFromGroupExcludeIdsQuery

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

Specified by:

getPollFromGroupExcludeIdsQuery in class AbstractChannelMessageStoreQueryProvider

Returns:

Sql Query

getPollFromGroupQuery

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

Specified by:

getPollFromGroupQuery in class AbstractChannelMessageStoreQueryProvider

Returns:

Sql Query