public interface BasicMessageGroupStore| 修飾子と型 | メソッドと説明 |
|---|---|
MessageGroup | addMessageToGroup(ObjectSE groupId, Message<?> message) グループ ID に関連付けてメッセージを保存します。 |
MessageGroup | getMessageGroup(ObjectSE groupId) このグループ ID で addMessageToGroup(Object, Message) を使用して保存された、現在 MessageStore にあるすべてのメッセージを返します。 |
int | messageGroupSize(ObjectSE groupId) この MessageGroup のサイズを返します。 |
Message<?> | pollMessageFromGroup(ObjectSE groupId) この MessageGroup からのメッセージをポーリングし(実装でサポートされている場合は FIFO スタイルで)、ポーリングされた Message も削除します |
void | removeMessageGroup(ObjectSE groupId) この ID のメッセージグループを削除します。 |
@ManagedAttribute int messageGroupSize(ObjectSE groupId)
groupId - グループ識別子。MessageGroup getMessageGroup(ObjectSE groupId)
addMessageToGroup(Object, Message) を使用して保存された、現在 MessageStore にあるすべてのメッセージを返します。groupId - グループ識別子。MessageGroup addMessageToGroup(ObjectSE groupId, Message<?> message)
groupId - メッセージを保存するグループ ID。message - メッセージ。Message<?> pollMessageFromGroup(ObjectSE groupId)
MessageGroup からのメッセージをポーリングし(実装でサポートされている場合は FIFO スタイルで)、ポーリングされた Message も削除します groupId - グループ識別子。void removeMessageGroup(ObjectSE groupId)
groupId - 削除するグループの ID。