ReceiversImpl.java |
/* * JBossMQ, the OpenSource JMS implementation * * Distributable under LGPL license. * See terms of license at gnu.org. */ package org.jboss.mq.server; import java.util.ArrayList; import java.util.HashSet; import java.util.Iterator; import org.jboss.mq.Subscription; /** * The default implementation of the Receivers interface. * * @author <a href="mailto:adrian@jboss.com">Adrian Brock</a> * @version $Revision: 1.2 $ */ public class ReceiversImpl implements Receivers { // Constants ----------------------------------------------------- // Attributes ---------------------------------------------------- /** The receivers */ HashSet receivers = new HashSet(); // Static -------------------------------------------------------- // Constructors -------------------------------------------------- // Public -------------------------------------------------------- // Receivers implementation -------------------------------------- public void add(Subscription sub) { receivers.add(sub); } public Iterator iterator() { return receivers.iterator(); } public ArrayList listReceivers() { return new ArrayList(receivers); } public void remove(Subscription sub) { receivers.remove(sub); } public int size() { return receivers.size(); } // Protected ----------------------------------------------------- // Package Private ----------------------------------------------- // Private ------------------------------------------------------- // Inner classes ------------------------------------------------- }
ReceiversImpl.java |