|
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectorg.apache.qpid.server.queue.ConcurrentDeliveryManager
public class ConcurrentDeliveryManager
Manages delivery of messages on behalf of a queue
Field Summary | |
---|---|
boolean |
compressBufferOnQueue
|
Method Summary | |
---|---|
void |
clearAllMessages()
|
void |
deliver(java.lang.String name,
AMQMessage msg)
Handles message delivery. |
java.util.List<AMQMessage> |
getMessages()
|
int |
getQueueMessageCount()
This method should not be used to determin if there are messages in the queue. |
boolean |
hasQueuedMessages()
Determines whether there are queued messages. |
void |
processAsync(java.util.concurrent.Executor executor)
Requests that the delivery manager start processing the queue asynchronously if there is work that can be done (i.e. |
void |
removeAMessageFromTop()
|
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Field Detail |
---|
public boolean compressBufferOnQueue
Method Detail |
---|
public boolean hasQueuedMessages()
public int getQueueMessageCount()
public java.util.List<AMQMessage> getMessages()
public void removeAMessageFromTop() throws org.apache.qpid.AMQException
org.apache.qpid.AMQException
public void clearAllMessages() throws org.apache.qpid.AMQException
org.apache.qpid.AMQException
public void processAsync(java.util.concurrent.Executor executor)
executor
- the executor on which the delivery should take placepublic void deliver(java.lang.String name, AMQMessage msg) throws FailedDequeueException
name
- the name of the entity on whose behalf we are delivering the messagemsg
- the message to deliver
FailedDequeueException
- if the message could not be dequeued
|
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |