org.apache.activemq.broker.region.group
Class SimpleMessageGroupMap
java.lang.Object
org.apache.activemq.broker.region.group.SimpleMessageGroupMap
- All Implemented Interfaces:
- MessageGroupMap
public class SimpleMessageGroupMap
- extends Object
- implements MessageGroupMap
A simple implementation which tracks every individual GroupID value but
which can become a memory leak if clients die before they complete a message
group.
- Version:
- $Revision: 564814 $
SimpleMessageGroupMap
public SimpleMessageGroupMap()
put
public void put(String groupId,
ConsumerId consumerId)
- Specified by:
put
in interface MessageGroupMap
get
public ConsumerId get(String groupId)
- Specified by:
get
in interface MessageGroupMap
removeGroup
public ConsumerId removeGroup(String groupId)
- Specified by:
removeGroup
in interface MessageGroupMap
removeConsumer
public MessageGroupSet removeConsumer(ConsumerId consumerId)
- Specified by:
removeConsumer
in interface MessageGroupMap
toString
public String toString()
- Overrides:
toString
in class Object
Copyright © 2005-2011 Apache Software Foundation. All Rights Reserved.