Uses of Interface
org.apache.qpid.server.queue.QueueEntry

Packages that use QueueEntry
org.apache.qpid.server   
org.apache.qpid.server.ack   
org.apache.qpid.server.handler   
org.apache.qpid.server.output   
org.apache.qpid.server.output.amqp0_8   
org.apache.qpid.server.output.amqp0_9   
org.apache.qpid.server.output.amqp0_9_1   
org.apache.qpid.server.queue   
org.apache.qpid.server.subscription   
org.apache.qpid.server.transport   
org.apache.qpid.server.txn   
org.apache.qpid.tools.messagestore.commands   
 

Uses of QueueEntry in org.apache.qpid.server
 

Methods in org.apache.qpid.server with parameters of type QueueEntry
 void AMQChannel.addUnacknowledgedMessage(QueueEntry entry, long deliveryTag, Subscription subscription)
          Add a message to the channel-based list of unacknowledged messages
 boolean ExtractResendAndRequeue.callback(long deliveryTag, QueueEntry message)
           
 

Constructor parameters in org.apache.qpid.server with type arguments of type QueueEntry
ExtractResendAndRequeue(UnacknowledgedMessageMap unacknowledgedMessageMap, Map<Long,QueueEntry> msgToRequeue, Map<Long,QueueEntry> msgToResend, boolean requeueIfUnabletoResend, TransactionLog txnLog)
           
ExtractResendAndRequeue(UnacknowledgedMessageMap unacknowledgedMessageMap, Map<Long,QueueEntry> msgToRequeue, Map<Long,QueueEntry> msgToResend, boolean requeueIfUnabletoResend, TransactionLog txnLog)
           
 

Uses of QueueEntry in org.apache.qpid.server.ack
 

Methods in org.apache.qpid.server.ack that return QueueEntry
 QueueEntry UnacknowledgedMessageMap.get(long deliveryTag)
           
 QueueEntry UnacknowledgedMessageMapImpl.get(long key)
           
 QueueEntry UnacknowledgedMessageMap.remove(long deliveryTag)
           
 QueueEntry UnacknowledgedMessageMapImpl.remove(long deliveryTag)
           
 

Methods in org.apache.qpid.server.ack that return types with arguments of type QueueEntry
 Collection<QueueEntry> UnacknowledgedMessageMap.cancelAllMessages()
           
 Collection<QueueEntry> UnacknowledgedMessageMapImpl.cancelAllMessages()
           
 

Methods in org.apache.qpid.server.ack with parameters of type QueueEntry
 void UnacknowledgedMessageMap.add(long deliveryTag, QueueEntry message)
           
 void UnacknowledgedMessageMapImpl.add(long deliveryTag, QueueEntry message)
           
 boolean UnacknowledgedMessageMap.Visitor.callback(long deliveryTag, QueueEntry message)
           
 

Method parameters in org.apache.qpid.server.ack with type arguments of type QueueEntry
 void UnacknowledgedMessageMap.collect(long deliveryTag, boolean multiple, Map<Long,QueueEntry> msgs)
           
 void UnacknowledgedMessageMapImpl.collect(long deliveryTag, boolean multiple, Map<Long,QueueEntry> msgs)
           
 void UnacknowledgedMessageMap.remove(Map<Long,QueueEntry> msgs)
           
 void UnacknowledgedMessageMapImpl.remove(Map<Long,QueueEntry> msgs)
           
 

Uses of QueueEntry in org.apache.qpid.server.handler
 

Methods in org.apache.qpid.server.handler with parameters of type QueueEntry
 boolean BasicGetMethodHandler.GetNoAckSubscription.wouldSuspend(QueueEntry msg)
           
 

Uses of QueueEntry in org.apache.qpid.server.output
 

Methods in org.apache.qpid.server.output with parameters of type QueueEntry
 void ProtocolOutputConverter.writeDeliver(QueueEntry entry, int channelId, long deliveryTag, org.apache.qpid.framing.AMQShortString consumerTag)
           
 void ProtocolOutputConverter.writeGetOk(QueueEntry message, int channelId, long deliveryTag, int queueSize)
           
 

Uses of QueueEntry in org.apache.qpid.server.output.amqp0_8
 

Methods in org.apache.qpid.server.output.amqp0_8 with parameters of type QueueEntry
 void ProtocolOutputConverterImpl.writeDeliver(QueueEntry entry, int channelId, long deliveryTag, org.apache.qpid.framing.AMQShortString consumerTag)
           
 void ProtocolOutputConverterImpl.writeGetOk(QueueEntry entry, int channelId, long deliveryTag, int queueSize)
           
 

Uses of QueueEntry in org.apache.qpid.server.output.amqp0_9
 

Methods in org.apache.qpid.server.output.amqp0_9 with parameters of type QueueEntry
 void ProtocolOutputConverterImpl.writeDeliver(QueueEntry entry, int channelId, long deliveryTag, org.apache.qpid.framing.AMQShortString consumerTag)
           
 void ProtocolOutputConverterImpl.writeGetOk(QueueEntry entry, int channelId, long deliveryTag, int queueSize)
           
 

Uses of QueueEntry in org.apache.qpid.server.output.amqp0_9_1
 

Methods in org.apache.qpid.server.output.amqp0_9_1 with parameters of type QueueEntry
 void ProtocolOutputConverterImpl.writeDeliver(QueueEntry entry, int channelId, long deliveryTag, org.apache.qpid.framing.AMQShortString consumerTag)
           
 void ProtocolOutputConverterImpl.writeGetOk(QueueEntry entry, int channelId, long deliveryTag, int queueSize)
           
 

Uses of QueueEntry in org.apache.qpid.server.queue
 

Classes in org.apache.qpid.server.queue that implement QueueEntry
 class QueueEntryImpl
           
 

Fields in org.apache.qpid.server.queue declared as QueueEntry
(package private)  QueueEntry QueueContext._lastSeenEntry
           
(package private)  QueueEntry QueueContext._releasedEntry
           
 

Fields in org.apache.qpid.server.queue with type parameters of type QueueEntry
(package private) static AtomicReferenceFieldUpdater<QueueContext,QueueEntry> QueueContext._lastSeenUpdater
           
(package private) static AtomicReferenceFieldUpdater<QueueContext,QueueEntry> QueueContext._releasedUpdater
           
 

Methods in org.apache.qpid.server.queue that return QueueEntry
 QueueEntry SimpleQueueEntryList.add(ServerMessage message)
           
 QueueEntry QueueEntryList.add(ServerMessage message)
           
 QueueEntry ConflationQueueList.add(ServerMessage message)
           
 QueueEntry PriorityQueueList.add(ServerMessage message)
           
 QueueEntry SimpleQueueEntryList.getHead()
           
 QueueEntry QueueEntryList.getHead()
           
 QueueEntry PriorityQueueList.getHead()
           
 QueueEntry AMQQueue.Context.getLastSeenEntry()
           
 QueueEntry QueueContext.getLastSeenEntry()
           
 QueueEntry AMQQueue.getMessageOnTheQueue(long messageId)
           
 QueueEntry SimpleAMQQueue.getMessageOnTheQueue(long messageId)
           
 QueueEntry SimpleQueueEntryList.QueueEntryIteratorImpl.getNode()
           
 QueueEntry QueueEntryIterator.getNode()
           
protected  QueueEntry SimpleAMQQueue.getOldestQueueEntry()
           
 QueueEntry SimpleQueueEntryList.next(QueueEntry node)
           
 QueueEntry QueueEntryList.next(QueueEntry node)
           
 QueueEntry PriorityQueueList.next(QueueEntry node)
           
 

Methods in org.apache.qpid.server.queue that return types with arguments of type QueueEntry
 List<QueueEntry> AMQQueue.getMessagesOnTheQueue()
           
 List<QueueEntry> SimpleAMQQueue.getMessagesOnTheQueue()
           
 List<QueueEntry> AMQQueue.getMessagesOnTheQueue(long fromMessageId, long toMessageId)
           
 List<QueueEntry> SimpleAMQQueue.getMessagesOnTheQueue(long fromMessageId, long toMessageId)
           
 List<QueueEntry> SimpleAMQQueue.getMessagesOnTheQueue(SimpleAMQQueue.QueueEntryFilter filter)
           
 List<QueueEntry> AMQQueue.getMessagesRangeOnTheQueue(long fromPosition, long toPosition)
          Returns a list of QueEntries from a given range of queue positions, eg messages 5 to 10 on the queue.
 List<QueueEntry> SimpleAMQQueue.getMessagesRangeOnTheQueue(long fromPosition, long toPosition)
          Returns a list of QueEntries from a given range of queue positions, eg messages 5 to 10 on the queue.
 

Methods in org.apache.qpid.server.queue with parameters of type QueueEntry
 boolean SimpleAMQQueue.QueueEntryFilter.accept(QueueEntry entry)
           
protected  void SimpleAMQQueue.checkSubscriptionsNotAheadOfDelivery(QueueEntry entry)
           
protected  void AMQPriorityQueue.checkSubscriptionsNotAheadOfDelivery(QueueEntry entry)
           
 int QueueEntryImpl.compareTo(QueueEntry o)
           
 void AMQQueue.dequeue(QueueEntry entry, Subscription sub)
           
 void SimpleAMQQueue.dequeue(QueueEntry entry, Subscription sub)
           
 QueueEntry SimpleQueueEntryList.next(QueueEntry node)
           
 QueueEntry QueueEntryList.next(QueueEntry node)
           
 QueueEntry PriorityQueueList.next(QueueEntry node)
           
 void BaseQueue.PostEnqueueAction.onEnqueue(QueueEntry entry)
           
 void AMQQueue.requeue(QueueEntry entry)
           
 void SimpleAMQQueue.requeue(QueueEntry entry)
           
 boolean AMQQueue.resend(QueueEntry entry, Subscription subscription)
           
 boolean SimpleAMQQueue.resend(QueueEntry entry, Subscription subscription)
           
 void InboundMessageAdapter.setEntry(QueueEntry entry)
           
 void QueueEntry.StateChangeListener.stateChanged(QueueEntry entry, QueueEntry.State oldSate, QueueEntry.State newState)
           
 

Constructors in org.apache.qpid.server.queue with parameters of type QueueEntry
InboundMessageAdapter(QueueEntry entry)
           
QueueContext(QueueEntry head)
           
 

Uses of QueueEntry in org.apache.qpid.server.subscription
 

Methods in org.apache.qpid.server.subscription with parameters of type QueueEntry
 void Subscription_0_10.acknowledge(QueueEntry entry)
           
 void ClientDeliveryMethod.deliverToClient(Subscription sub, QueueEntry entry, long deliveryTag)
           
 boolean Subscription.hasInterest(QueueEntry msg)
           
 boolean SubscriptionImpl.hasInterest(QueueEntry entry)
           
 boolean Subscription_0_10.hasInterest(QueueEntry entry)
           
 void Subscription.onDequeue(QueueEntry queueEntry)
           
 void SubscriptionImpl.onDequeue(QueueEntry queueEntry)
           
 void Subscription_0_10.onDequeue(QueueEntry queueEntry)
           
protected  void SubscriptionImpl.recordMessageDelivery(QueueEntry entry, long deliveryTag)
           
 void RecordDeliveryMethod.recordMessageDelivery(Subscription sub, QueueEntry entry, long deliveryTag)
           
(package private)  void Subscription_0_10.reject(QueueEntry entry)
           
(package private)  void Subscription_0_10.release(QueueEntry entry)
           
 void Subscription.restoreCredit(QueueEntry queueEntry)
           
 void SubscriptionImpl.restoreCredit(QueueEntry queueEntry)
           
 void Subscription_0_10.restoreCredit(QueueEntry queueEntry)
           
 void Subscription.send(QueueEntry msg)
           
abstract  void SubscriptionImpl.send(QueueEntry msg)
          This method can be called by each of the publisher threads.
 void SubscriptionImpl.BrowserSubscription.send(QueueEntry msg)
          This method can be called by each of the publisher threads.
 void SubscriptionImpl.NoAckSubscription.send(QueueEntry entry)
          This method can be called by each of the publisher threads.
 void SubscriptionImpl.AckSubscription.send(QueueEntry entry)
          This method can be called by each of the publisher threads.
 void Subscription_0_10.send(QueueEntry entry)
           
protected  void SubscriptionImpl.sendToClient(QueueEntry entry, long deliveryTag)
           
 boolean Subscription.wouldSuspend(QueueEntry msg)
           
 boolean SubscriptionImpl.wouldSuspend(QueueEntry msg)
           
 boolean SubscriptionImpl.BrowserSubscription.wouldSuspend(QueueEntry msg)
           
 boolean SubscriptionImpl.NoAckSubscription.wouldSuspend(QueueEntry msg)
           
 boolean Subscription_0_10.wouldSuspend(QueueEntry msg)
           
 

Constructors in org.apache.qpid.server.subscription with parameters of type QueueEntry
ExplicitAcceptDispositionChangeListener(QueueEntry entry, Subscription_0_10 subscription_0_10)
           
ImplicitAcceptDispositionChangeListener(QueueEntry entry, Subscription_0_10 subscription_0_10)
           
MessageAcceptCompletionListener(Subscription_0_10 sub, ServerSession session, QueueEntry entry, boolean restoreCredit)
           
 

Uses of QueueEntry in org.apache.qpid.server.transport
 

Methods in org.apache.qpid.server.transport with parameters of type QueueEntry
 void ServerSession.acknowledge(Subscription_0_10 sub, QueueEntry entry)
           
 

Uses of QueueEntry in org.apache.qpid.server.txn
 

Method parameters in org.apache.qpid.server.txn with type arguments of type QueueEntry
 void ServerTransaction.dequeue(Collection<QueueEntry> ackedMessages, ServerTransaction.Action postCommitAction)
           
 void AutoCommitTransaction.dequeue(Collection<QueueEntry> ackedMessages, ServerTransaction.Action postCommitAction)
           
 void LocalTransaction.dequeue(Collection<QueueEntry> queueEntries, ServerTransaction.Action postCommitAction)
           
 

Uses of QueueEntry in org.apache.qpid.tools.messagestore.commands
 

Method parameters in org.apache.qpid.tools.messagestore.commands with type arguments of type QueueEntry
protected  List<List> Show.createMessageData(List<Long> msgids, List<QueueEntry> messages, boolean showHeaders, boolean showRouting, boolean showMessageHeaders)
          Create the list data for display from the messages.
protected  List<List> Dump.createMessageData(List<Long> msgids, List<QueueEntry> messages, boolean showHeaders, boolean showRouting, boolean showMessageHeaders)
           
 



Licensed to the Apache Software Foundation