public class CachedMessageGroupMap extends Object implements MessageGroupMap
Modifier and Type | Method and Description |
---|---|
ConsumerId |
get(String groupId) |
Map<String,String> |
getGroups() |
int |
getMaximumCacheSize() |
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 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 int getMaximumCacheSize()
public void setDestination(Destination destination)
setDestination
in interface MessageGroupMap
Copyright © 2005–2018. All rights reserved.