1 18 package org.apache.activemq.broker.region.group; 19 20 import org.apache.activemq.command.ConsumerId; 21 22 27 public interface MessageGroupMap { 28 29 void put(String groupId, ConsumerId consumerId); 30 31 ConsumerId get(String groupId); 32 33 ConsumerId removeGroup(String groupId); 34 35 MessageGroupSet removeConsumer(ConsumerId consumerId); 36 37 } 38 | Popular Tags |