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.

Constructor Summary

Constructors

Constructor and Description
MessageGroupHashBucket(int bucketCount)

Method Summary

Methods

Modifier and Type	Method and Description
protected MessageGroupSet	createMessageGroupSet(int bucketNumber)
protected MessageGroupSet	createMessageGroupSet(int bucketNumber, MessageGroupSet parent)
ConsumerId	get(java.lang.String groupId)
protected int	getBucketNumber(java.lang.String groupId)
void	put(java.lang.String groupId, ConsumerId consumerId)
MessageGroupSet	removeConsumer(ConsumerId consumerId)
ConsumerId	removeGroup(java.lang.String groupId)
java.lang.String	toString()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Constructor Detail

MessageGroupHashBucket

public MessageGroupHashBucket(int bucketCount)

Method Detail

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)