インターフェース BasicMessageGroupStore

すべての既知のサブインターフェース:
ChannelMessageStore、MessageGroupStore、PriorityCapableChannelMessageStore
すべての既知の実装クラス:
AbstractBatchingMessageGroupStore、AbstractConfigurableMongoDbMessageStore、AbstractKeyValueMessageStore、AbstractMessageGroupStore、ConfigurableMongoDbMessageStore、HazelcastMessageStore、JdbcChannelMessageStore、JdbcMessageStore、MongoDbChannelMessageStore、MongoDbMessageStore、RedisChannelMessageStore、RedisChannelPriorityMessageStore、RedisMessageStore、SimpleMessageStore
public interface BasicMessageGroupStore
基本的な機能を備えた最小限のメッセージグループストアを定義します。
導入:
4.0
作成者:
Gary Russell

  • メソッドの詳細

    • messageGroupSize

      @ManagedAttribute int messageGroupSize(ObjectSE groupId)
      この MessageGroup のサイズを返します。
      パラメーター:
      groupId - グループ識別子。
      戻り値:
      サイズ。

    • getMessageGroup

      MessageGroup getMessageGroup(ObjectSE groupId)
      このグループ ID で addMessageToGroup(Object, Message) を使用して保存された、現在 MessageStore にあるすべてのメッセージを返します。
      パラメーター:
      groupId - グループ識別子。
      戻り値:
      メッセージのグループ。このキーにメッセージが存在しない場合は空です。

    • addMessageToGroup

      MessageGroup addMessageToGroup(ObjectSE groupId, Message<?> message)
      グループ ID に関連付けてメッセージを保存します。これは、メッセージをグループ化するために使用できます。
      パラメーター:
      groupId - メッセージを保存するグループ ID。
      message - メッセージ。
      戻り値:
      メッセージグループ。

    • pollMessageFromGroup

      Message<?> pollMessageFromGroup(ObjectSE groupId)
      この MessageGroup からのメッセージのポーリング（実装でサポートされている場合は FIFO スタイル）と同時に、ポーリングされた Message も削除します。
      パラメーター:
      groupId - グループ識別子。
      戻り値:
      メッセージ。

    • removeMessageGroup

      void removeMessageGroup(ObjectSE groupId)
      この ID のメッセージグループを削除します。
      パラメーター:
      groupId - 削除するグループの ID。