クラス ConfigurableMongoDbMessageStore

メソッドの詳細

• addMessage

  public <T> Message<T> addMessage(Message<T> message)

  インターフェースからコピーされた説明: MessageStore

  提供されたメッセージを MessageStore に入れます。ストアはメッセージを内部で変更する必要がある場合があり、その場合、戻り値は入力と異なる場合があります。戻り値の ID は、MessageStore.getMessage(UUID) および MessageStore.removeMessage(UUID) が正しく動作するようにインデックスとして使用されます。メッセージは不変であるため、同じメッセージを複数回入力しても何も起こりません。

  次で指定:

  インターフェース MessageStore の addMessage 

  型パラメーター:

  T - ペイロード型。

  パラメーター:

  message - メッセージ。

  戻り値:

  保存されたメッセージ。

• removeMessage

  public Message<?> removeMessage(UUIDSE id)

  インターフェースからコピーされた説明: MessageStore

  指定された ID を持つメッセージが MessageStore から削除されます (存在する場合)。その ID を持つメッセージがストアに存在しない場合は、null が返されます。このメソッドが MessageGroupStore に実装されている場合、このメッセージを保持するグループがない場合にのみ、メッセージはストアから削除されます。

  次で指定:

  インターフェース MessageStore の removeMessage 

  パラメーター:

  id - メッセージ識別子。

  戻り値:

  メッセージ (ある場合)。

• getMessageCount

  public long getMessageCount()

  インターフェースからコピーされた説明: MessageStore

  ストア内のメッセージ数を示すオプションの属性。実装は例外をスローすることで応答を拒否する場合があります。

  次で指定:

  インターフェース MessageStore の getMessageCount 

  戻り値:

  メッセージの数。

• getMessageGroup

  public MessageGroup getMessageGroup(ObjectSE groupId)

  インターフェースからコピーされた説明: BasicMessageGroupStore

  このグループ ID で BasicMessageGroupStore.addMessageToGroup(Object, Message) を使用して保存された、現在 MessageStore にあるすべてのメッセージを返します。

  次で指定:

  インターフェース BasicMessageGroupStore の getMessageGroup 

  パラメーター:

  groupId - グループ識別子。

  戻り値:

  メッセージのグループ。このキーにメッセージが存在しない場合は空です。

• addMessageToGroup

  public MessageGroup addMessageToGroup(ObjectSE groupId, Message<?> message)

  インターフェースからコピーされた説明: BasicMessageGroupStore

  グループ ID に関連付けてメッセージを保存します。これは、メッセージをグループ化するために使用できます。

  次で指定:

  インターフェース BasicMessageGroupStore の addMessageToGroup 

  オーバーライド:

  クラス AbstractMessageGroupStore の addMessageToGroup 

  パラメーター:

  groupId - メッセージを保存するグループ ID。

  message - メッセージ。

  戻り値:

  メッセージグループ。

• doAddMessagesToGroup

  protected void doAddMessagesToGroup(ObjectSE groupId, Message<?>... messages)

  オーバーライド:

  クラス AbstractConfigurableMongoDbMessageStore の doAddMessagesToGroup 

• doRemoveMessagesFromGroup

  protected void doRemoveMessagesFromGroup(ObjectSE groupId, CollectionSE<Message<?>> messages)

  オーバーライド:

  クラス AbstractConfigurableMongoDbMessageStore の doRemoveMessagesFromGroup 

• getMessageFromGroup

  @Nullable public Message<?> getMessageFromGroup(ObjectSE groupId, UUIDSE messageId)

  インターフェースからコピーされた説明: MessageGroupStore

  ID を使用してグループから Message を取得します。メッセージがリクエストされたグループに属していない場合は、null を返します。

  次で指定:

  インターフェース MessageGroupStore の getMessageFromGroup 

  パラメーター:

  groupId - メッセージを含むグループの groupId。

  messageId - メッセージ ID。

  戻り値:

  リクエストされたグループに属している場合は、ID によるメッセージ。

• doRemoveMessageFromGroupById

  protected boolean doRemoveMessageFromGroupById(ObjectSE groupId, UUIDSE messageId)

  オーバーライド:

  クラス AbstractMessageGroupStore の doRemoveMessageFromGroupById 

• doPollMessageFromGroup

  protected Message<?> doPollMessageFromGroup(ObjectSE groupId)

  次で指定:

  クラス AbstractMessageGroupStore の doPollMessageFromGroup 

• doSetLastReleasedSequenceNumberForGroup

  protected void doSetLastReleasedSequenceNumberForGroup(ObjectSE groupId, int sequenceNumber)

  オーバーライド:

  クラス AbstractConfigurableMongoDbMessageStore の doSetLastReleasedSequenceNumberForGroup 

• doSetGroupCondition

  protected void doSetGroupCondition(ObjectSE groupId, StringSE condition)

  オーバーライド:

  クラス AbstractConfigurableMongoDbMessageStore の doSetGroupCondition 

• doCompleteGroup

  protected void doCompleteGroup(ObjectSE groupId)

  オーバーライド:

  クラス AbstractConfigurableMongoDbMessageStore の doCompleteGroup 

• iterator

  public IteratorSE<MessageGroup> iterator()

  次で指定:

  インターフェース IterableSE<MessageGroup> の iterator 

  次で指定:

  インターフェース MessageGroupStore の iterator 

  オーバーライド:

  クラス AbstractConfigurableMongoDbMessageStore の iterator 

  戻り値:

  現在累積されている MessageGroup の反復子。

• getMessageCountForAllMessageGroups

  @ManagedAttribute public int getMessageCountForAllMessageGroups()

  インターフェースからコピーされた説明: MessageGroupStore

  すべてのグループにわたるストア内のメッセージの数を示すオプションの属性。実装は、例外をスローすることによって応答を拒否する場合があります。

  次で指定:

  インターフェース MessageGroupStore の getMessageCountForAllMessageGroups 

  オーバーライド:

  クラス AbstractMessageGroupStore の getMessageCountForAllMessageGroups 

  戻り値:

  メッセージの数

• getMessageGroupCount

  @ManagedAttribute public int getMessageGroupCount()

  インターフェースからコピーされた説明: MessageGroupStore

  メッセージグループの数を示すオプションの属性。実装は、例外をスローすることによって応答を拒否する場合があります。

  次で指定:

  インターフェース MessageGroupStore の getMessageGroupCount 

  オーバーライド:

  クラス AbstractMessageGroupStore の getMessageGroupCount 

  戻り値:

  メッセージグループの数

• getOneMessageFromGroup

  public Message<?> getOneMessageFromGroup(ObjectSE groupId)

  インターフェースからコピーされた説明: MessageGroupStore

  MessageGroup から 1 つの Message を返します。

  次で指定:

  インターフェース MessageGroupStore の getOneMessageFromGroup 

  オーバーライド:

  クラス AbstractConfigurableMongoDbMessageStore の getOneMessageFromGroup 

  パラメーター:

  groupId - グループ識別子。

  戻り値:

  Message

• getMessagesForGroup

  public CollectionSE<Message<?>> getMessagesForGroup(ObjectSE groupId)

  インターフェースからコピーされた説明: MessageGroupStore

  指定されたグループ ID のメッセージを取得します。

  次で指定:

  インターフェース MessageGroupStore の getMessagesForGroup 

  オーバーライド:

  クラス AbstractConfigurableMongoDbMessageStore の getMessagesForGroup 

  パラメーター:

  groupId - メッセージを取得するグループ ID。

  戻り値:

  グループのメッセージ。

• streamMessagesForGroup

  public StreamSE<Message<?>> streamMessagesForGroup(ObjectSE groupId)

  インターフェースからコピーされた説明: MessageGroupStore

  指定されたグループに保存されているメッセージのストリームを返します。永続的な実装は、完全に処理されたら閉じる必要があるストリームを返します（たとえば、try-with-resources 句を使用）。デフォルトでは、MessageGroupStore.getMessagesForGroup(Object) の結果をストリーミングします。

  次で指定:

  インターフェース MessageGroupStore の streamMessagesForGroup 

  パラメーター:

  groupId - メッセージを取得するためのグループ ID。

  戻り値:

  このグループのメッセージの StreamSE。