|
||||||||||
PREV NEXT | FRAMES NO FRAMES |
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)
|
|
||||||||||
PREV NEXT | FRAMES NO FRAMES |