public class SimpleMessageGroupMap extends Object implements MessageGroupMap
Constructor and Description |
---|
SimpleMessageGroupMap() |
Modifier and Type | Method and Description |
---|---|
ConsumerId |
get(String groupId) |
Map<String,String> |
getGroups() |
String |
getType() |
void |
put(String groupId,
ConsumerId consumerId) |
void |
removeAll() |
MessageGroupSet |
removeConsumer(ConsumerId consumerId) |
ConsumerId |
removeGroup(String groupId) |
void |
setDestination(Destination destination) |
String |
toString() |
public SimpleMessageGroupMap()
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
public void removeAll()
removeAll
in interface MessageGroupMap
public Map<String,String> getGroups()
getGroups
in interface MessageGroupMap
public String getType()
getType
in interface MessageGroupMap
public void setDestination(Destination destination)
setDestination
in interface MessageGroupMap
Copyright © 2005–2018 The Apache Software Foundation. All rights reserved.