public class SimpleMessageGroupMap extends Object implements MessageGroupMap
Constructor and Description |
---|
SimpleMessageGroupMap() |
Modifier and Type | Method and Description |
---|---|
ConsumerId |
get(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
Copyright © 2005–2015 The Apache Software Foundation. All rights reserved.