public class MessageGroupHashBucket extends 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(String groupId) |
protected int |
getBucketNumber(String groupId) |
void |
put(String groupId,
ConsumerId consumerId) |
MessageGroupSet |
removeConsumer(ConsumerId consumerId) |
ConsumerId |
removeGroup(String groupId) |
String |
toString() |
public void put(String groupId, ConsumerId consumerId)
put
in interface MessageGroupMap
public ConsumerId get(String groupId)
get
in interface MessageGroupMap
public ConsumerId removeGroup(String groupId)
removeGroup
in interface MessageGroupMap
public MessageGroupSet removeConsumer(ConsumerId consumerId)
removeConsumer
in interface MessageGroupMap
protected MessageGroupSet createMessageGroupSet(int bucketNumber, MessageGroupSet parent)
protected MessageGroupSet createMessageGroupSet(int bucketNumber)
protected int getBucketNumber(String groupId)
Copyright © 2005-2013 The Apache Software Foundation. All Rights Reserved.