org.apache.activemq.broker.region.group
Class MessageGroupHashBucket
java.lang.Object
org.apache.activemq.broker.region.group.MessageGroupHashBucket
- All Implemented Interfaces:
- MessageGroupMap
public class MessageGroupHashBucket
- extends java.lang.Object
- implements MessageGroupMap
Uses hash-code buckets to associate consumers with sets of message group IDs.
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait |
MessageGroupHashBucket
public MessageGroupHashBucket(int bucketCount)
put
public void put(java.lang.String groupId,
ConsumerId consumerId)
- Specified by:
put
in interface MessageGroupMap
get
public ConsumerId get(java.lang.String groupId)
- Specified by:
get
in interface MessageGroupMap
removeGroup
public ConsumerId removeGroup(java.lang.String groupId)
- Specified by:
removeGroup
in interface MessageGroupMap
removeConsumer
public MessageGroupSet removeConsumer(ConsumerId consumerId)
- Specified by:
removeConsumer
in interface MessageGroupMap
toString
public java.lang.String toString()
- Overrides:
toString
in class java.lang.Object
createMessageGroupSet
protected MessageGroupSet createMessageGroupSet(int bucketNumber,
MessageGroupSet parent)
createMessageGroupSet
protected MessageGroupSet createMessageGroupSet(int bucketNumber)
getBucketNumber
protected int getBucketNumber(java.lang.String groupId)
Copyright © 2005-2011. All Rights Reserved.