| 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 |