Modifier and Type | Interface and Description |
---|---|
interface |
PagedReference
A PagedReference
|
Modifier and Type | Class and Description |
---|---|
class |
PagedReferenceImpl
A InternalReference
|
Modifier and Type | Method and Description |
---|---|
MessageReference |
PagedReferenceImpl.copy(Queue queue) |
Modifier and Type | Method and Description |
---|---|
void |
StorageManager.updateDeliveryCount(MessageReference ref) |
void |
StorageManager.updateScheduledDeliveryTime(MessageReference ref) |
void |
StorageManager.updateScheduledDeliveryTimeTransactional(long txID,
MessageReference ref) |
Modifier and Type | Method and Description |
---|---|
List<MessageReference> |
JournalStorageManager.PageUpdateTXEncoding.getRelatedMessageReferences() |
Modifier and Type | Method and Description |
---|---|
void |
LargeServerMessageImpl.setOriginalHeaders(ServerMessage other,
MessageReference originalReference,
boolean expiry) |
void |
JournalStorageManager.updateDeliveryCount(MessageReference ref) |
void |
JournalStorageManager.updateScheduledDeliveryTime(MessageReference ref) |
void |
JournalStorageManager.updateScheduledDeliveryTimeTransactional(long txID,
MessageReference ref) |
Modifier and Type | Method and Description |
---|---|
void |
NullStorageManager.updateDeliveryCount(MessageReference ref) |
void |
NullStorageManager.updateScheduledDeliveryTime(MessageReference ref) |
void |
NullStorageManager.updateScheduledDeliveryTimeTransactional(long txID,
MessageReference ref) |
Modifier and Type | Method and Description |
---|---|
MessageReference |
PostOffice.reroute(ServerMessage message,
Queue queue,
Transaction tx) |
Modifier and Type | Method and Description |
---|---|
MessageReference |
PostOfficeImpl.reroute(ServerMessage message,
Queue queue,
Transaction tx) |
Modifier and Type | Method and Description |
---|---|
MessageReference |
MessageReference.copy(Queue queue) |
MessageReference |
ServerMessage.createReference(Queue queue) |
MessageReference |
Queue.getReference(long id) |
MessageReference |
ServerConsumer.removeReferenceByID(long messageID) |
MessageReference |
ScheduledDeliveryHandler.removeReferenceWithID(long id) |
MessageReference |
Queue.removeReferenceWithID(long id) |
Modifier and Type | Method and Description |
---|---|
List<MessageReference> |
ScheduledDeliveryHandler.cancel(Filter filter) |
List<MessageReference> |
ServerConsumer.cancelRefs(boolean failed,
boolean lastConsumedAsDelivered,
Transaction tx) |
Map<String,List<MessageReference>> |
Queue.getDeliveringMessages()
Return a Map consisting of consumer.toString and its messages
Delivering message is a property of the consumer, this method will aggregate the results per Server's consumer object
|
List<MessageReference> |
Consumer.getDeliveringMessages()
Add the in-deliver mode messages to the ref-list passed as parameter
|
List<MessageReference> |
ServerSession.getInTXMessagesForConsumer(long consumerId) |
List<MessageReference> |
Queue.getScheduledMessages() |
List<MessageReference> |
ScheduledDeliveryHandler.getScheduledReferences() |
LinkedListIterator<MessageReference> |
Queue.iterator() |
LinkedListIterator<MessageReference> |
Queue.totalIterator() |
Modifier and Type | Method and Description |
---|---|
void |
Queue.acknowledge(MessageReference ref) |
void |
Queue.acknowledge(Transaction tx,
MessageReference ref) |
void |
Queue.addHead(MessageReference ref) |
void |
Queue.addTail(MessageReference ref) |
void |
Queue.addTail(MessageReference ref,
boolean direct) |
void |
HornetQServerLogger.bridgeUnableToSendMessage(Exception e,
MessageReference ref) |
void |
Queue.cancel(MessageReference reference,
long timeBase) |
void |
Queue.cancel(Transaction tx,
MessageReference ref) |
void |
Queue.cancel(Transaction tx,
MessageReference ref,
boolean ignoreRedeliveryCheck) |
boolean |
ScheduledDeliveryHandler.checkAndSchedule(MessageReference ref,
boolean tail) |
boolean |
Queue.checkRedelivery(MessageReference ref,
long timeBase,
boolean ignoreRedeliveryDelay) |
void |
HornetQServerLogger.errorBrowserHandlingMessage(Exception e,
MessageReference current) |
void |
HornetQServerLogger.errorCancellingRefOnBridge(Exception e,
MessageReference ref2) |
void |
HornetQServerLogger.errorExpiringReferencesOnQueue(Exception e,
MessageReference ref) |
void |
Queue.expire(MessageReference ref) |
HandleStatus |
Consumer.handle(MessageReference reference)
There was a change on semantic during 2.3 here.
We now first accept the message, and the actual deliver is done as part of Consumer.proceedDeliver(MessageReference) . |
ServerMessage |
ServerMessage.makeCopyForExpiryOrDLA(long newID,
MessageReference originalReference,
boolean expiry) |
void |
HornetQServerLogger.messageExceededMaxDelivery(MessageReference ref,
SimpleString name) |
void |
HornetQServerLogger.messageExceededMaxDeliverySendtoDLA(MessageReference ref,
SimpleString name,
SimpleString simpleString) |
void |
Consumer.proceedDeliver(MessageReference reference)
This will proceed with the actual delivery.
|
void |
Queue.reacknowledge(Transaction tx,
MessageReference ref) |
void |
Queue.reload(MessageReference ref) |
void |
HornetQServerLogger.removingBadConsumer(Throwable e,
Consumer consumer,
MessageReference reference) |
void |
ServerMessage.setOriginalHeaders(ServerMessage other,
MessageReference originalReference,
boolean expiry) |
Modifier and Type | Method and Description |
---|---|
void |
Queue.addHead(List<MessageReference> refs) |
Modifier and Type | Method and Description |
---|---|
List<MessageReference> |
BridgeImpl.getDeliveringMessages() |
List<MessageReference> |
Redistributor.getDeliveringMessages() |
Modifier and Type | Method and Description |
---|---|
HandleStatus |
BridgeImpl.handle(MessageReference ref) |
HandleStatus |
Redistributor.handle(MessageReference reference) |
void |
BridgeImpl.proceedDeliver(MessageReference ref) |
void |
Redistributor.proceedDeliver(MessageReference ref) |
Modifier and Type | Class and Description |
---|---|
class |
MessageReferenceImpl
Implementation of a MessageReference
|
Modifier and Type | Method and Description |
---|---|
MessageReference |
MessageReferenceImpl.copy(Queue queue) |
MessageReference |
ServerMessageImpl.createReference(Queue queue) |
MessageReference |
QueueImpl.getReference(long id1) |
MessageReference |
ServerConsumerImpl.removeReferenceByID(long messageID) |
MessageReference |
ScheduledDeliveryHandlerImpl.removeReferenceWithID(long id) |
MessageReference |
QueueImpl.removeReferenceWithID(long id1) |
Modifier and Type | Method and Description |
---|---|
List<MessageReference> |
ScheduledDeliveryHandlerImpl.cancel(Filter filter) |
LinkedList<MessageReference> |
ServerConsumerImpl.cancelRefs(boolean failed,
boolean lastConsumedAsDelivered,
Transaction tx) |
List<MessageReference> |
ServerConsumerImpl.getDeliveringMessages() |
Map<String,List<MessageReference>> |
QueueImpl.getDeliveringMessages() |
List<MessageReference> |
ServerSessionImpl.getInTXMessagesForConsumer(long consumerId) |
List<MessageReference> |
QueueImpl.RefsOperation.getListOnConsumer(long consumerID) |
List<MessageReference> |
QueueImpl.RefsOperation.getRelatedMessageReferences() |
List<MessageReference> |
QueueImpl.getScheduledMessages() |
List<MessageReference> |
ScheduledDeliveryHandlerImpl.getScheduledReferences() |
LinkedListIterator<MessageReference> |
QueueImpl.iterator() |
Modifier and Type | Method and Description |
---|---|
void |
QueueImpl.acknowledge(MessageReference ref) |
void |
QueueImpl.acknowledge(Transaction tx,
MessageReference ref) |
void |
QueueImpl.addHead(MessageReference ref) |
void |
LastValueQueue.addHead(MessageReference ref) |
void |
ScheduledDeliveryHandlerImpl.addInPlace(long deliveryTime,
MessageReference ref,
boolean tail) |
void |
QueueImpl.addTail(MessageReference ref) |
void |
QueueImpl.addTail(MessageReference ref,
boolean direct) |
void |
LastValueQueue.addTail(MessageReference ref,
boolean direct) |
void |
QueueImpl.cancel(MessageReference reference,
long timeBase) |
void |
QueueImpl.cancel(Transaction tx,
MessageReference reference) |
void |
QueueImpl.cancel(Transaction tx,
MessageReference reference,
boolean ignoreRedeliveryCheck) |
boolean |
ScheduledDeliveryHandlerImpl.checkAndSchedule(MessageReference ref,
boolean tail) |
boolean |
QueueImpl.checkRedelivery(MessageReference reference,
long timeBase,
boolean ignoreRedeliveryDelay) |
void |
QueueImpl.expire(MessageReference ref) |
HandleStatus |
ServerConsumerImpl.handle(MessageReference ref) |
ServerMessage |
ServerMessageImpl.makeCopyForExpiryOrDLA(long newID,
MessageReference originalReference,
boolean expiry) |
protected void |
QueueImpl.postAcknowledge(MessageReference ref) |
void |
ServerConsumerImpl.proceedDeliver(MessageReference reference) |
void |
QueueImpl.reacknowledge(Transaction tx,
MessageReference ref) |
protected void |
QueueImpl.refAdded(MessageReference ref) |
protected void |
QueueImpl.refRemoved(MessageReference ref) |
protected void |
LastValueQueue.refRemoved(MessageReference ref) |
void |
QueueImpl.reload(MessageReference ref) |
void |
ServerMessageImpl.setOriginalHeaders(ServerMessage other,
MessageReference originalReference,
boolean expiry) |
Modifier and Type | Method and Description |
---|---|
void |
QueueImpl.addHead(List<MessageReference> refs) |
void |
JournalLoader.handlePreparedAcknowledge(long messageID,
List<MessageReference> referencesToAck,
long queueID) |
void |
PostOfficeJournalLoader.handlePreparedAcknowledge(long messageID,
List<MessageReference> referencesToAck,
long queueID) |
void |
JournalLoader.handlePreparedTransaction(Transaction tx,
List<MessageReference> referencesToAck,
Xid xid,
ResourceManager resourceManager) |
void |
PostOfficeJournalLoader.handlePreparedTransaction(Transaction tx,
List<MessageReference> referencesToAck,
Xid xid,
ResourceManager resourceManager) |
Modifier and Type | Method and Description |
---|---|
List<MessageReference> |
TransactionOperationAbstract.getListOnConsumer(long consumerID) |
List<MessageReference> |
TransactionOperation.getListOnConsumer(long consumerID) |
List<MessageReference> |
TransactionOperationAbstract.getRelatedMessageReferences() |
List<MessageReference> |
TransactionOperation.getRelatedMessageReferences() |
Copyright © 2017 JBoss, a division of Red Hat. All Rights Reserved.