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 |
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 |
Delivery.getReference() |
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) |
List<MessageReference> |
Queue.getScheduledMessages() |
List<MessageReference> |
ScheduledDeliveryHandler.getScheduledReferences() |
LinkedListIterator<MessageReference> |
Queue.iterator() |
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 |
Queue.cancel(MessageReference reference,
long timeBase) |
void |
Queue.cancel(Transaction tx,
MessageReference ref) |
boolean |
ScheduledDeliveryHandler.checkAndSchedule(MessageReference ref,
boolean tail) |
boolean |
Queue.checkRedelivery(MessageReference ref,
long timeBase) |
void |
Queue.expire(MessageReference ref) |
HandleStatus |
Consumer.handle(MessageReference reference) |
void |
Queue.reacknowledge(Transaction tx,
MessageReference ref) |
void |
Queue.reload(MessageReference ref) |
Modifier and Type | Method and Description |
---|---|
HandleStatus |
Redistributor.handle(MessageReference reference) |
HandleStatus |
BridgeImpl.handle(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 |
DeliveryImpl.getReference() |
MessageReference |
QueueImpl.getReference(long id) |
MessageReference |
ServerConsumerImpl.removeReferenceByID(long messageID) |
MessageReference |
ScheduledDeliveryHandlerImpl.removeReferenceWithID(long id) |
MessageReference |
QueueImpl.removeReferenceWithID(long id) |
Modifier and Type | Method and Description |
---|---|
List<MessageReference> |
ScheduledDeliveryHandlerImpl.cancel(Filter filter) |
LinkedList<MessageReference> |
ServerConsumerImpl.cancelRefs(boolean failed,
boolean lastConsumedAsDelivered,
Transaction tx) |
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 |
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) |
boolean |
ScheduledDeliveryHandlerImpl.checkAndSchedule(MessageReference ref,
boolean tail) |
boolean |
QueueImpl.checkRedelivery(MessageReference reference,
long timeBase) |
void |
QueueImpl.expire(MessageReference ref) |
HandleStatus |
ServerConsumerImpl.handle(MessageReference ref) |
protected void |
QueueImpl.postAcknowledge(MessageReference ref) |
void |
QueueImpl.reacknowledge(Transaction tx,
MessageReference ref) |
protected void |
QueueImpl.refAdded(MessageReference ref) |
void |
QueueImpl.reload(MessageReference ref) |
Constructor and Description |
---|
DeliveryImpl(long consumerID,
MessageReference reference) |
Modifier and Type | Method and Description |
---|---|
List<MessageReference> |
TransactionOperationAbstract.getRelatedMessageReferences() |
List<MessageReference> |
TransactionOperation.getRelatedMessageReferences() |
Copyright © 2012 JBoss by Red Hat. All Rights Reserved.