public final class PriorityMessageQueue extends AbstractMessageQueue
enqueueFirst(org.apache.qpid.jms.message.JmsInboundMessageDispatch)
is
used.Constructor and Description |
---|
PriorityMessageQueue() |
Modifier and Type | Method and Description |
---|---|
void |
clear()
Clears the Queue of any Messages.
|
void |
enqueue(JmsInboundMessageDispatch envelope)
Adds the given message envelope to the end of the Message queue.
|
void |
enqueueFirst(JmsInboundMessageDispatch envelope)
Adds the given message envelope to the front of the Message queue.
|
boolean |
isEmpty() |
protected JmsInboundMessageDispatch |
peekFirst()
Returns but does not remove the first entry in the implementation queue.
|
List<JmsInboundMessageDispatch> |
removeAll()
Removes and returns all Messages in the Queue.
|
protected JmsInboundMessageDispatch |
removeFirst()
Removes and returns the first entry in the implementation queue.
|
int |
size()
Returns the number of Messages currently in the Queue.
|
close, dequeue, dequeueNoWait, getLock, isClosed, isRunning, peek, start, stop
public void enqueue(JmsInboundMessageDispatch envelope)
MessageQueue
envelope
- The in-bound Message envelope to enqueue.public void enqueueFirst(JmsInboundMessageDispatch envelope)
MessageQueue
envelope
- The in-bound Message envelope to enqueue.public boolean isEmpty()
public int size()
MessageQueue
public void clear()
MessageQueue
public List<JmsInboundMessageDispatch> removeAll()
MessageQueue
protected JmsInboundMessageDispatch removeFirst()
AbstractMessageQueue
removeFirst
in class AbstractMessageQueue
protected JmsInboundMessageDispatch peekFirst()
AbstractMessageQueue
peekFirst
in class AbstractMessageQueue
Copyright © 2013–2016 The Apache Software Foundation. All rights reserved.