Modifier and Type | Method and Description |
---|---|
MessageEnqueueRecord |
MessageInstance.getEnqueueRecord() |
Modifier and Type | Method and Description |
---|---|
MessageEnqueueRecord |
QueueEntryImpl.getEnqueueRecord() |
Modifier and Type | Method and Description |
---|---|
QueueEntry |
QueueEntryList.add(ServerMessage message,
MessageEnqueueRecord enqueueRecord) |
org.apache.qpid.server.queue.LastValueQueueList.ConflationQueueEntry |
LastValueQueueList.add(ServerMessage message,
MessageEnqueueRecord enqueueRecord)
Updates the list using super.add and also updates
LastValueQueueList._latestValuesMap and discards entries as necessary. |
QueueEntry |
OrderedQueueEntryList.add(ServerMessage message,
MessageEnqueueRecord enqueueRecord) |
SortedQueueEntry |
SortedQueueEntryList.add(ServerMessage message,
MessageEnqueueRecord enqueueRecord) |
protected abstract OrderedQueueEntry |
OrderedQueueEntryList.createQueueEntry(ServerMessage<?> message,
MessageEnqueueRecord enqueueRecord) |
protected StandardQueueEntry |
StandardQueueEntryList.createQueueEntry(ServerMessage<?> message,
MessageEnqueueRecord enqueueRecord) |
protected org.apache.qpid.server.queue.LastValueQueueList.ConflationQueueEntry |
LastValueQueueList.createQueueEntry(ServerMessage message,
MessageEnqueueRecord enqueueRecord) |
protected void |
SortedQueueImpl.doEnqueue(ServerMessage message,
Action<? super MessageInstance> action,
MessageEnqueueRecord record) |
protected void |
AbstractQueue.doEnqueue(ServerMessage message,
Action<? super MessageInstance> action,
MessageEnqueueRecord enqueueRecord) |
void |
BaseQueue.enqueue(ServerMessage message,
Action<? super MessageInstance> action,
MessageEnqueueRecord record) |
void |
AbstractQueue.enqueue(ServerMessage message,
Action<? super MessageInstance> action,
MessageEnqueueRecord enqueueRecord) |
void |
AMQQueue.recover(ServerMessage<?> message,
MessageEnqueueRecord enqueueRecord) |
void |
AbstractQueue.recover(ServerMessage message,
MessageEnqueueRecord enqueueRecord) |
Constructor and Description |
---|
OrderedQueueEntry(OrderedQueueEntryList queueEntryList,
ServerMessage message,
MessageEnqueueRecord messageEnqueueRecord) |
QueueEntryImpl(QueueEntryList queueEntryList,
ServerMessage message,
long entryId,
MessageEnqueueRecord enqueueRecord) |
QueueEntryImpl(QueueEntryList queueEntryList,
ServerMessage message,
MessageEnqueueRecord enqueueRecord) |
SortedQueueEntry(SortedQueueEntryList queueEntryList,
ServerMessage message,
long entryId,
MessageEnqueueRecord messageEnqueueRecord) |
StandardQueueEntry(StandardQueueEntryList queueEntryList,
ServerMessage message,
MessageEnqueueRecord messageEnqueueRecord) |
Modifier and Type | Method and Description |
---|---|
MessageEnqueueRecord |
AbstractJDBCMessageStore.JDBCTransaction.enqueueMessage(TransactionLogResource queue,
EnqueueableMessage message) |
MessageEnqueueRecord |
Transaction.enqueueMessage(TransactionLogResource queue,
EnqueueableMessage message)
Places a message onto a specified queue, in a given transactional context.
|
MessageEnqueueRecord |
Transaction.DequeueRecord.getEnqueueRecord() |
Modifier and Type | Method and Description |
---|---|
void |
AbstractJDBCMessageStore.JDBCTransaction.dequeueMessage(MessageEnqueueRecord enqueueRecord) |
void |
Transaction.dequeueMessage(MessageEnqueueRecord enqueueRecord) |
Modifier and Type | Class and Description |
---|---|
static class |
AbstractBDBMessageStore.BDBEnqueueRecord |
Modifier and Type | Method and Description |
---|---|
boolean |
MessageInstanceHandler.handle(MessageEnqueueRecord record) |
Modifier and Type | Method and Description |
---|---|
void |
DtxBranch.dequeue(MessageEnqueueRecord record) |
void |
AutoCommitTransaction.dequeue(MessageEnqueueRecord record,
ServerTransaction.Action postTransactionAction) |
void |
AsyncAutoCommitTransaction.dequeue(MessageEnqueueRecord record,
ServerTransaction.Action postTransactionAction) |
void |
ServerTransaction.dequeue(MessageEnqueueRecord record,
ServerTransaction.Action postTransactionAction)
Dequeue a message from a queue registering a post transaction action.
|
void |
LocalTransaction.dequeue(MessageEnqueueRecord record,
ServerTransaction.Action postTransactionAction) |
void |
DistributedTransaction.dequeue(MessageEnqueueRecord record,
ServerTransaction.Action postTransactionAction) |
void |
ServerTransaction.EnqueueAction.postCommit(MessageEnqueueRecord... records) |
Modifier and Type | Method and Description |
---|---|
void |
DtxBranch.enqueue(TransactionLogResource queue,
EnqueueableMessage message,
Action<MessageEnqueueRecord> enqueueAction) |
Copyright © 2006–2016 The Apache Software Foundation. All rights reserved.