Uses of Interface
org.apache.activemq.artemis.core.server.MessageReference

Packages that use MessageReference

Package	Description
org.apache.activemq.artemis.core.management.impl.openmbean
org.apache.activemq.artemis.core.paging.cursor
org.apache.activemq.artemis.core.persistence
org.apache.activemq.artemis.core.persistence.impl.journal
org.apache.activemq.artemis.core.persistence.impl.journal.codec
org.apache.activemq.artemis.core.persistence.impl.nullpm
org.apache.activemq.artemis.core.postoffice
org.apache.activemq.artemis.core.postoffice.impl
org.apache.activemq.artemis.core.protocol.core.impl
org.apache.activemq.artemis.core.server
org.apache.activemq.artemis.core.server.cluster.impl
org.apache.activemq.artemis.core.server.impl
org.apache.activemq.artemis.core.transaction
org.apache.activemq.artemis.spi.core.protocol

Uses of MessageReference in org.apache.activemq.artemis.core.management.impl.openmbean

Methods in org.apache.activemq.artemis.core.management.impl.openmbean with parameters of type MessageReference

Modifier and Type	Method and Description
static CompositeData	OpenTypeSupport.convert(MessageReference ref)

Uses of MessageReference in org.apache.activemq.artemis.core.paging.cursor

Subinterfaces of MessageReference in org.apache.activemq.artemis.core.paging.cursor

Modifier and Type	Interface and Description
interface	PagedReference

Classes in org.apache.activemq.artemis.core.paging.cursor that implement MessageReference

Modifier and Type	Class and Description
class	PagedReferenceImpl

Methods in org.apache.activemq.artemis.core.paging.cursor that return MessageReference

Modifier and Type	Method and Description
MessageReference	PagedReferenceImpl.copy(Queue queue)

Uses of MessageReference in org.apache.activemq.artemis.core.persistence

Methods in org.apache.activemq.artemis.core.persistence with parameters of type MessageReference

Modifier and Type	Method and Description
void	StorageManager.updateDeliveryCount(MessageReference ref)
void	StorageManager.updateScheduledDeliveryTime(MessageReference ref)
void	StorageManager.updateScheduledDeliveryTimeTransactional(long txID, MessageReference ref)

Uses of MessageReference in org.apache.activemq.artemis.core.persistence.impl.journal

Methods in org.apache.activemq.artemis.core.persistence.impl.journal with parameters of type MessageReference

Modifier and Type	Method and Description
void	LargeServerMessageImpl.setOriginalHeaders(ServerMessage other, MessageReference originalReference, boolean expiry)
void	AbstractJournalStorageManager.updateDeliveryCount(MessageReference ref)
void	AbstractJournalStorageManager.updateScheduledDeliveryTime(MessageReference ref)
void	AbstractJournalStorageManager.updateScheduledDeliveryTimeTransactional(long txID, MessageReference ref)

Uses of MessageReference in org.apache.activemq.artemis.core.persistence.impl.journal.codec

Methods in org.apache.activemq.artemis.core.persistence.impl.journal.codec that return types with arguments of type MessageReference

Modifier and Type	Method and Description
List<MessageReference>	PageUpdateTXEncoding.getRelatedMessageReferences()

Uses of MessageReference in org.apache.activemq.artemis.core.persistence.impl.nullpm

Methods in org.apache.activemq.artemis.core.persistence.impl.nullpm with parameters of type MessageReference

Modifier and Type	Method and Description
void	NullStorageManager.updateDeliveryCount(MessageReference ref)
void	NullStorageManager.updateScheduledDeliveryTime(MessageReference ref)
void	NullStorageManager.updateScheduledDeliveryTimeTransactional(long txID, MessageReference ref)

Uses of MessageReference in org.apache.activemq.artemis.core.postoffice

Methods in org.apache.activemq.artemis.core.postoffice that return MessageReference

Modifier and Type	Method and Description
MessageReference	PostOffice.reroute(ServerMessage message, Queue queue, Transaction tx)

Uses of MessageReference in org.apache.activemq.artemis.core.postoffice.impl

Methods in org.apache.activemq.artemis.core.postoffice.impl that return MessageReference

Modifier and Type	Method and Description
MessageReference	PostOfficeImpl.reroute(ServerMessage message, Queue queue, Transaction tx)

Methods in org.apache.activemq.artemis.core.postoffice.impl that return types with arguments of type MessageReference

Modifier and Type	Method and Description
List<MessageReference>	PostOfficeImpl.AddOperation.getListOnConsumer(long consumerID)
List<MessageReference>	PostOfficeImpl.AddOperation.getRelatedMessageReferences()

Uses of MessageReference in org.apache.activemq.artemis.core.protocol.core.impl

Methods in org.apache.activemq.artemis.core.protocol.core.impl with parameters of type MessageReference

Modifier and Type	Method and Description
int	CoreSessionCallback.sendLargeMessage(MessageReference ref, ServerMessage message, ServerConsumer consumer, long bodySize, int deliveryCount)
int	CoreSessionCallback.sendMessage(MessageReference ref, ServerMessage message, ServerConsumer consumer, int deliveryCount)
boolean	CoreSessionCallback.updateDeliveryCountAfterCancel(ServerConsumer consumer, MessageReference ref, boolean failed)

Uses of MessageReference in org.apache.activemq.artemis.core.server

Methods in org.apache.activemq.artemis.core.server that return MessageReference

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)

Methods in org.apache.activemq.artemis.core.server that return types with arguments of type MessageReference

Modifier and Type	Method and Description
LinkedListIterator<MessageReference>	Queue.browserIterator()
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()
List<MessageReference>	ServerConsumer.getDeliveringReferencesBasedOnProtocol(boolean remove, Object protocolDataStart, Object protocolDataEnd)
List<MessageReference>	ServerSession.getInTXMessagesForConsumer(long consumerId)
List<MessageReference>	Queue.getScheduledMessages()
List<MessageReference>	ScheduledDeliveryHandler.getScheduledReferences()
LinkedListIterator<MessageReference>	Queue.iterator() It will iterate thorugh memory only (not paging)

Methods in org.apache.activemq.artemis.core.server with parameters of type MessageReference

Modifier and Type	Method and Description
void	Queue.acknowledge(MessageReference ref)
void	Queue.acknowledge(MessageReference ref, AckReason reason)
void	Queue.acknowledge(Transaction tx, MessageReference ref)
void	Queue.acknowledge(Transaction tx, MessageReference ref, AckReason reason)
void	Queue.addHead(MessageReference ref, boolean scheduling)
void	Queue.addTail(MessageReference ref)
void	Queue.addTail(MessageReference ref, boolean direct)
void	ServerConsumer.backToDelivering(MessageReference reference) Some protocols may choose to send the message back to delivering instead of redeliver.
void	ActiveMQServerLogger.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	ActiveMQServerLogger.errorBrowserHandlingMessage(Exception e, MessageReference current)
void	ActiveMQServerLogger.errorCancellingRefOnBridge(Exception e, MessageReference ref2)
void	ActiveMQServerLogger.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, boolean copyOriginalHeaders)
void	ActiveMQServerLogger.messageExceededMaxDelivery(MessageReference ref, SimpleString name)
void	ActiveMQServerLogger.messageExceededMaxDeliveryNoDLA(MessageReference ref, SimpleString name)
void	ActiveMQServerLogger.messageExceededMaxDeliverySendtoDLA(MessageReference ref, SimpleString name, SimpleString simpleString)
void	Queue.postAcknowledge(MessageReference ref)
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	ActiveMQServerLogger.removingBadConsumer(Throwable e, Consumer consumer, MessageReference reference)
void	Queue.sendToDeadLetterAddress(Transaction tx, MessageReference ref)
void	ServerMessage.setOriginalHeaders(ServerMessage other, MessageReference originalReference, boolean expiry)

Method parameters in org.apache.activemq.artemis.core.server with type arguments of type MessageReference

Modifier and Type	Method and Description
void	Queue.addHead(List<MessageReference> refs, boolean scheduling)

Uses of MessageReference in org.apache.activemq.artemis.core.server.cluster.impl

Methods in org.apache.activemq.artemis.core.server.cluster.impl that return types with arguments of type MessageReference

Modifier and Type	Method and Description
List<MessageReference>	Redistributor.getDeliveringMessages()
List<MessageReference>	BridgeImpl.getDeliveringMessages()

Methods in org.apache.activemq.artemis.core.server.cluster.impl with parameters of type MessageReference

Modifier and Type	Method and Description
HandleStatus	Redistributor.handle(MessageReference reference)
HandleStatus	BridgeImpl.handle(MessageReference ref)
void	Redistributor.proceedDeliver(MessageReference ref)
void	BridgeImpl.proceedDeliver(MessageReference ref)

Uses of MessageReference in org.apache.activemq.artemis.core.server.impl

Classes in org.apache.activemq.artemis.core.server.impl that implement MessageReference

Modifier and Type	Class and Description
class	MessageReferenceImpl Implementation of a MessageReference

Fields in org.apache.activemq.artemis.core.server.impl declared as MessageReference

Modifier and Type	Field and Description
protected MessageReference	ServerConsumerImpl.BrowserDeliverer.current

Fields in org.apache.activemq.artemis.core.server.impl with type parameters of type MessageReference

Modifier and Type	Field and Description
protected Deque<MessageReference>	ServerConsumerImpl.deliveringRefs
LinkedListIterator<MessageReference>	ServerConsumerImpl.BrowserDeliverer.iterator

Methods in org.apache.activemq.artemis.core.server.impl that return 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)

Methods in org.apache.activemq.artemis.core.server.impl that return types with arguments of type MessageReference

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>	ServerConsumerImpl.getDeliveringReferencesBasedOnProtocol(boolean remove, Object protocolDataStart, Object protocolDataEnd) Remove references based on the protocolData.
List<MessageReference>	ServerSessionImpl.getInTXMessagesForConsumer(long consumerId)
List<MessageReference>	RefsOperation.getListOnConsumer(long consumerID)
List<MessageReference>	RefsOperation.getReferencesToAcknowledge()
List<MessageReference>	RefsOperation.getRelatedMessageReferences()
List<MessageReference>	QueueImpl.getScheduledMessages()
List<MessageReference>	ScheduledDeliveryHandlerImpl.getScheduledReferences()
LinkedListIterator<MessageReference>	QueueImpl.iterator()

Methods in org.apache.activemq.artemis.core.server.impl with parameters of type MessageReference

Modifier and Type	Method and Description
void	QueueImpl.acknowledge(MessageReference ref)
void	QueueImpl.acknowledge(MessageReference ref, AckReason reason)
void	QueueImpl.acknowledge(Transaction tx, MessageReference ref)
void	QueueImpl.acknowledge(Transaction tx, MessageReference ref, AckReason reason)
void	QueueImpl.addHead(MessageReference ref, boolean scheduling)
void	LastValueQueue.addHead(MessageReference ref, boolean scheduling)
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	ServerConsumerImpl.backToDelivering(MessageReference reference)
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)
ServerMessage	ServerMessageImpl.makeCopyForExpiryOrDLA(long newID, MessageReference originalReference, boolean expiry, boolean copyOriginalHeaders)
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)
protected boolean	QueueImpl.scheduleIfPossible(MessageReference ref)
void	QueueImpl.sendToDeadLetterAddress(Transaction tx, MessageReference ref)
void	ServerMessageImpl.setOriginalHeaders(ServerMessage other, MessageReference originalReference, boolean expiry)
protected void	ServerConsumerImpl.updateDeliveryCountForCanceledRef(MessageReference ref, boolean failed)

Method parameters in org.apache.activemq.artemis.core.server.impl with type arguments of type MessageReference

Modifier and Type	Method and Description
void	QueueImpl.addHead(List<MessageReference> refs, boolean scheduling)
void	PostOfficeJournalLoader.handlePreparedAcknowledge(long messageID, List<MessageReference> referencesToAck, long queueID)
void	JournalLoader.handlePreparedAcknowledge(long messageID, List<MessageReference> referencesToAck, long queueID)
void	PostOfficeJournalLoader.handlePreparedTransaction(Transaction tx, List<MessageReference> referencesToAck, Xid xid, ResourceManager resourceManager)
void	JournalLoader.handlePreparedTransaction(Transaction tx, List<MessageReference> referencesToAck, Xid xid, ResourceManager resourceManager)

Constructor parameters in org.apache.activemq.artemis.core.server.impl with type arguments of type MessageReference

Constructor and Description
BrowserDeliverer(LinkedListIterator<MessageReference> iterator)

Uses of MessageReference in org.apache.activemq.artemis.core.transaction

Methods in org.apache.activemq.artemis.core.transaction that return types with arguments of type MessageReference

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()

Uses of MessageReference in org.apache.activemq.artemis.spi.core.protocol

Methods in org.apache.activemq.artemis.spi.core.protocol with parameters of type MessageReference

Modifier and Type	Method and Description
int	SessionCallback.sendLargeMessage(MessageReference reference, ServerMessage message, ServerConsumer consumerID, long bodySize, int deliveryCount)
int	SessionCallback.sendMessage(MessageReference ref, ServerMessage message, ServerConsumer consumerID, int deliveryCount)
boolean	SessionCallback.updateDeliveryCountAfterCancel(ServerConsumer consumer, MessageReference ref, boolean failed) Use this to updates specifics on the message after a redelivery happened.