org.apache.qpid.server.queue
Class ClusteredQueue

java.lang.Object
  extended by org.apache.qpid.server.queue.AMQQueue
      extended by org.apache.qpid.server.queue.ClusteredQueue
All Implemented Interfaces:
org.apache.qpid.server.management.Managable

public class ClusteredQueue
extends org.apache.qpid.server.queue.AMQQueue

Represents a shared queue in a cluster. The key difference is that as well as any local consumers, there may be consumers for this queue on other members of the cluster.


Constructor Summary
ClusteredQueue(GroupManager groupMgr, java.lang.String name, boolean durable, java.lang.String owner, boolean autoDelete, org.apache.qpid.server.queue.QueueRegistry queueRegistry)
           
ClusteredQueue(GroupManager groupMgr, java.lang.String name, boolean durable, java.lang.String owner, boolean autoDelete, org.apache.qpid.server.queue.QueueRegistry queueRegistry, java.util.concurrent.Executor asyncDelivery)
           
 
Method Summary
 void addRemoteSubcriber(MemberHandle peer)
           
protected  void autodelete()
           
 void deliver(org.apache.qpid.server.queue.AMQMessage message)
           
 void removeAllRemoteSubscriber(MemberHandle peer)
           
 void removeRemoteSubscriber(MemberHandle peer)
           
 void unregisterProtocolSession(org.apache.qpid.server.protocol.AMQProtocolSession ps, int channel, java.lang.String consumerTag)
           
 
Methods inherited from class org.apache.qpid.server.queue.AMQQueue
bind, delete, delete, deliverAsync, equals, getManagedObject, getMessageCount, getName, getOwner, getSubscribers, hashCode, isAutoDelete, isDurable, isShared, registerProtocolSession, toString, updateReceivedMessageCount
 
Methods inherited from class java.lang.Object
clone, finalize, getClass, notify, notifyAll, wait, wait, wait
 

Constructor Detail

ClusteredQueue

public ClusteredQueue(GroupManager groupMgr,
                      java.lang.String name,
                      boolean durable,
                      java.lang.String owner,
                      boolean autoDelete,
                      org.apache.qpid.server.queue.QueueRegistry queueRegistry)
               throws org.apache.qpid.AMQException
Throws:
org.apache.qpid.AMQException

ClusteredQueue

public ClusteredQueue(GroupManager groupMgr,
                      java.lang.String name,
                      boolean durable,
                      java.lang.String owner,
                      boolean autoDelete,
                      org.apache.qpid.server.queue.QueueRegistry queueRegistry,
                      java.util.concurrent.Executor asyncDelivery)
               throws org.apache.qpid.AMQException
Throws:
org.apache.qpid.AMQException
Method Detail

deliver

public void deliver(org.apache.qpid.server.queue.AMQMessage message)
             throws org.apache.qpid.AMQException
Overrides:
deliver in class org.apache.qpid.server.queue.AMQQueue
Throws:
org.apache.qpid.AMQException

autodelete

protected void autodelete()
                   throws org.apache.qpid.AMQException
Overrides:
autodelete in class org.apache.qpid.server.queue.AMQQueue
Throws:
org.apache.qpid.AMQException

unregisterProtocolSession

public void unregisterProtocolSession(org.apache.qpid.server.protocol.AMQProtocolSession ps,
                                      int channel,
                                      java.lang.String consumerTag)
                               throws org.apache.qpid.AMQException
Overrides:
unregisterProtocolSession in class org.apache.qpid.server.queue.AMQQueue
Throws:
org.apache.qpid.AMQException

addRemoteSubcriber

public void addRemoteSubcriber(MemberHandle peer)

removeRemoteSubscriber

public void removeRemoteSubscriber(MemberHandle peer)

removeAllRemoteSubscriber

public void removeAllRemoteSubscriber(MemberHandle peer)