Class CachedMessageGroupMap
- java.lang.Object
-
- org.apache.activemq.broker.region.group.CachedMessageGroupMap
-
- All Implemented Interfaces:
MessageGroupMap
public class CachedMessageGroupMap extends Object implements MessageGroupMap
A simple implementation which tracks every individual GroupID value in a LRUCache
-
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description ConsumerIdget(String groupId)Map<String,String>getGroups()intgetMaximumCacheSize()StringgetType()voidput(String groupId, ConsumerId consumerId)voidremoveAll()MessageGroupSetremoveConsumer(ConsumerId consumerId)ConsumerIdremoveGroup(String groupId)voidsetDestination(Destination destination)StringtoString()
-
-
-
Method Detail
-
put
public void put(String groupId, ConsumerId consumerId)
- Specified by:
putin interfaceMessageGroupMap
-
get
public ConsumerId get(String groupId)
- Specified by:
getin interfaceMessageGroupMap
-
removeGroup
public ConsumerId removeGroup(String groupId)
- Specified by:
removeGroupin interfaceMessageGroupMap
-
removeConsumer
public MessageGroupSet removeConsumer(ConsumerId consumerId)
- Specified by:
removeConsumerin interfaceMessageGroupMap
-
removeAll
public void removeAll()
- Specified by:
removeAllin interfaceMessageGroupMap
-
getGroups
public Map<String,String> getGroups()
- Specified by:
getGroupsin interfaceMessageGroupMap- Returns:
- a map of group names and associated consumer Id
-
getType
public String getType()
- Specified by:
getTypein interfaceMessageGroupMap
-
getMaximumCacheSize
public int getMaximumCacheSize()
-
setDestination
public void setDestination(Destination destination)
- Specified by:
setDestinationin interfaceMessageGroupMap
-
-