public class MessageGroupHashBucket extends java.lang.Object implements MessageGroupMap
Constructor and Description |
---|
MessageGroupHashBucket(int bucketCount) |
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() |
public MessageGroupHashBucket(int bucketCount)
public void put(java.lang.String groupId, ConsumerId consumerId)
put
in interface MessageGroupMap
public ConsumerId get(java.lang.String groupId)
get
in interface MessageGroupMap
public ConsumerId removeGroup(java.lang.String groupId)
removeGroup
in interface MessageGroupMap
public MessageGroupSet removeConsumer(ConsumerId consumerId)
removeConsumer
in interface MessageGroupMap
public java.lang.String toString()
toString
in class java.lang.Object
protected MessageGroupSet createMessageGroupSet(int bucketNumber, MessageGroupSet parent)
protected MessageGroupSet createMessageGroupSet(int bucketNumber)
protected int getBucketNumber(java.lang.String groupId)
Copyright © 2005-2012. All Rights Reserved.