クラス RedisChannelPriorityMessageStore
java.lang.ObjectSE
org.springframework.integration.redis.store.RedisChannelMessageStore
org.springframework.integration.redis.store.RedisChannelPriorityMessageStore
- 実装されたすべてのインターフェース:
Aware、BeanClassLoaderAware、BeanNameAware、InitializingBean、BasicMessageGroupStore、ChannelMessageStore、PriorityCapableChannelMessageStore
public class RedisChannelPriorityMessageStore
extends RedisChannelMessageStore
implements PriorityCapableChannelMessageStore
リストを使用して QueueChannel をバックアップする特殊な Redis
PriorityCapableChannelMessageStore。メッセージは優先順に削除されます（IntegrationMessageHeaderAccessor.PRIORITY）。優先度 0 〜 9 がサポートされます（9 が最高）。無効な優先度の値は、優先度ヘッダーのないメッセージと同じ優先度（なし）で処理されます（優先度のあるメッセージの後に取得されます）。groupId が文字列である必要があります。
- 導入:
- 4.0
- 作成者:
- Gary Russell, Artem Bilan
コンストラクターのサマリー
コンストラクターメソッドのサマリー
修飾子と型メソッド説明addMessageToGroup(ObjectSE groupId, Message<?> message) グループ ID に関連付けてメッセージを保存します。intgetMessageGroup(ObjectSE groupId) このグループ ID でBasicMessageGroupStore.addMessageToGroup(Object, Message)を使用して保存された、現在 MessageStore にあるすべてのメッセージを返します。intbooleanintmessageGroupSize(ObjectSE groupId) この MessageGroup のサイズを返します。Message<?>pollMessageFromGroup(ObjectSE groupId) このMessageGroupからのメッセージのポーリング（実装でサポートされている場合は FIFO スタイル）と同時に、ポーリングされたMessageも削除します。voidremoveMessageGroup(ObjectSE groupId) この ID のメッセージグループを削除します。クラス org.springframework.integration.redis.store.RedisChannelMessageStore から継承されたメソッド
afterPropertiesSet, getBeanName, getMessageGroupFactory, getRedisTemplate, setBeanClassLoader, setBeanName, setMessageGroupFactory, setValueSerializer
コンストラクターの詳細
RedisChannelPriorityMessageStore
メソッドの詳細
isPriorityEnabled
public boolean isPriorityEnabled()- 次で指定:
- インターフェース
PriorityCapableChannelMessageStoreのisPriorityEnabled - 戻り値:
- このチャネルメッセージストアでメッセージ優先度が有効になっている場合は true。
messageGroupSize
インターフェースからコピーされた説明:BasicMessageGroupStoreこの MessageGroup のサイズを返します。- 次で指定:
- インターフェース
BasicMessageGroupStoreのmessageGroupSize - オーバーライド:
- クラス
RedisChannelMessageStoreのmessageGroupSize - パラメーター:
groupId- グループ識別子。- 戻り値:
- サイズ。
getMessageGroup
インターフェースからコピーされた説明:BasicMessageGroupStoreこのグループ ID でBasicMessageGroupStore.addMessageToGroup(Object, Message)を使用して保存された、現在 MessageStore にあるすべてのメッセージを返します。- 次で指定:
- インターフェース
BasicMessageGroupStoreのgetMessageGroup - オーバーライド:
- クラス
RedisChannelMessageStoreのgetMessageGroup - パラメーター:
groupId- グループ識別子。- 戻り値:
- メッセージのグループ。このキーにメッセージが存在しない場合は空です。
addMessageToGroup
インターフェースからコピーされた説明:BasicMessageGroupStoreグループ ID に関連付けてメッセージを保存します。これは、メッセージをグループ化するために使用できます。- 次で指定:
- インターフェース
BasicMessageGroupStoreのaddMessageToGroup - オーバーライド:
- クラス
RedisChannelMessageStoreのaddMessageToGroup - パラメーター:
groupId- メッセージを保存するグループ ID。message- メッセージ。- 戻り値:
- メッセージグループ。
pollMessageFromGroup
インターフェースからコピーされた説明:BasicMessageGroupStoreこのMessageGroupからのメッセージのポーリング（実装でサポートされている場合は FIFO スタイル）と同時に、ポーリングされたMessageも削除します。- 次で指定:
- インターフェース
BasicMessageGroupStoreのpollMessageFromGroup - オーバーライド:
- クラス
RedisChannelMessageStoreのpollMessageFromGroup - パラメーター:
groupId- グループ識別子。- 戻り値:
- メッセージ。
getMessageGroupCount
- オーバーライド:
- クラス
RedisChannelMessageStoreのgetMessageGroupCount
removeMessageGroup
インターフェースからコピーされた説明:BasicMessageGroupStoreこの ID のメッセージグループを削除します。- 次で指定:
- インターフェース
BasicMessageGroupStoreのremoveMessageGroup - オーバーライド:
- クラス
RedisChannelMessageStoreのremoveMessageGroup - パラメーター:
groupId- 削除するグループの ID。
getMessageCountForAllMessageGroups
- オーバーライド:
- クラス
RedisChannelMessageStoreのgetMessageCountForAllMessageGroups