org.apache.activemq.broker.region.group
Class SimpleMessageGroupMap

java.lang.Object
  extended by 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.


Constructor Summary
SimpleMessageGroupMap()
           
 
Method Summary
 ConsumerId get(String groupId)
           
 void put(String groupId, ConsumerId consumerId)
           
 MessageGroupSet removeConsumer(ConsumerId consumerId)
           
 ConsumerId removeGroup(String groupId)
           
 String toString()
           
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
 

Constructor Detail

SimpleMessageGroupMap

public SimpleMessageGroupMap()
Method Detail

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-2013 The Apache Software Foundation. All Rights Reserved.