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) |
Modifier and Type | Class and Description |
---|---|
class |
CachedMessageGroupMap
A simple implementation which tracks every individual GroupID value in a LRUCache
|
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 |
SimpleMessageGroupMapFactory.createMessageGroupMap() |
MessageGroupMap |
MessageGroupHashBucketFactory.createMessageGroupMap() |
MessageGroupMap |
MessageGroupMapFactory.createMessageGroupMap() |
MessageGroupMap |
CachedMessageGroupMapFactory.createMessageGroupMap() |
Copyright © 2005–2020 FuseSource, Corp.. All rights reserved.