org.apache.qpid.server.queue
Class RemoteQueueProxy
java.lang.Object
org.apache.qpid.server.queue.AMQQueue
org.apache.qpid.server.queue.RemoteQueueProxy
- All Implemented Interfaces:
- org.apache.qpid.server.management.Managable
public class RemoteQueueProxy
- extends org.apache.qpid.server.queue.AMQQueue
TODO: separate out an abstract base class from AMQQueue from which this inherits. It does
not require all the functionality currently in AMQQueue.
Constructor Summary |
RemoteQueueProxy(MemberHandle target,
GroupManager groupMgr,
java.lang.String name,
boolean durable,
java.lang.String owner,
boolean autoDelete,
org.apache.qpid.server.queue.QueueRegistry queueRegistry)
|
RemoteQueueProxy(MemberHandle target,
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 |
deliver(org.apache.qpid.server.queue.AMQMessage msg)
|
Methods inherited from class org.apache.qpid.server.queue.AMQQueue |
autodelete, bind, delete, delete, deliverAsync, equals, getManagedObject, getMessageCount, getName, getOwner, getSubscribers, hashCode, isAutoDelete, isDurable, isShared, registerProtocolSession, toString, unregisterProtocolSession, updateReceivedMessageCount |
Methods inherited from class java.lang.Object |
clone, finalize, getClass, notify, notifyAll, wait, wait, wait |
RemoteQueueProxy
public RemoteQueueProxy(MemberHandle target,
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
RemoteQueueProxy
public RemoteQueueProxy(MemberHandle target,
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
deliver
public void deliver(org.apache.qpid.server.queue.AMQMessage msg)
throws org.apache.qpid.server.queue.NoConsumersException
- Overrides:
deliver
in class org.apache.qpid.server.queue.AMQQueue
- Throws:
org.apache.qpid.server.queue.NoConsumersException