public interface BasicMessageGroupStore
Modifier and Type | Method and Description |
---|---|
MessageGroup |
addMessageToGroup(java.lang.Object groupId,
org.springframework.messaging.Message<?> message)
Store a message with an association to a group id.
|
MessageGroup |
getMessageGroup(java.lang.Object groupId)
Return all Messages currently in the MessageStore that were stored using
addMessageToGroup(Object, Message) with this group id. |
int |
messageGroupSize(java.lang.Object groupId)
Returns the size of this MessageGroup.
|
org.springframework.messaging.Message<?> |
pollMessageFromGroup(java.lang.Object groupId)
Polls Message from this
MessageGroup (in FIFO style if supported by the implementation)
while also removing the polled Message |
void |
removeMessageGroup(java.lang.Object groupId)
Remove the message group with this id.
|
@ManagedAttribute int messageGroupSize(java.lang.Object groupId)
groupId
- The group identifier.MessageGroup getMessageGroup(java.lang.Object groupId)
addMessageToGroup(Object, Message)
with this group id.groupId
- The group identifier.MessageGroup addMessageToGroup(java.lang.Object groupId, org.springframework.messaging.Message<?> message)
groupId
- The group id to store the message under.message
- A message.org.springframework.messaging.Message<?> pollMessageFromGroup(java.lang.Object groupId)
MessageGroup
(in FIFO style if supported by the implementation)
while also removing the polled Message
groupId
- The group identifier.void removeMessageGroup(java.lang.Object groupId)
groupId
- The id of the group to remove.