Package | Description |
---|---|
org.apache.activemq.broker.region |
Region abstraction and implementations in the Broker.
|
org.apache.activemq.broker.region.group |
Classes to implement the Message Groups feature.
|
Modifier and Type | Method and Description |
---|---|
MessageGroupMap |
Queue.getMessageGroupOwners() |
Modifier and Type | Method and Description |
---|---|
protected void |
Queue.assignGroup(Subscription subs,
MessageGroupMap messageGroupOwners,
MessageReference n,
String groupId) |
protected void |
QueueSubscription.assignGroupToMe(MessageGroupMap messageGroupOwners,
MessageReference n,
String groupId)
Assigns the message group to this subscription and set the flag on the
message that it is the first message to be dispatched.
|
Modifier and Type | Class and Description |
---|---|
class |
MessageGroupHashBucket
Uses hash-code buckets to associate consumers with sets of message group IDs.
|
class |
SimpleMessageGroupMap
A simple implementation which tracks every individual GroupID value but
which can become a memory leak if clients die before they complete a message
group.
|
Modifier and Type | Method and Description |
---|---|
MessageGroupMap |
MessageGroupHashBucketFactory.createMessageGroupMap() |
MessageGroupMap |
SimpleMessageGroupMapFactory.createMessageGroupMap() |
MessageGroupMap |
MessageGroupMapFactory.createMessageGroupMap() |
Copyright © 2005–2015. All rights reserved.