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.server.plugin
org.apache.activemq.artemis.core.server.plugin.impl
org.apache.activemq.artemis.core.server.transformer
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)

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

Modifier and Type	Method and Description
void	PagedReferenceImpl.onDelivery(Consumer<? super MessageReference> onDelivery)

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	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(Message 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(Message 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, Message message, ServerConsumer consumer, long bodySize, int deliveryCount)
int	CoreSessionCallback.sendMessage(MessageReference ref, Message 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)
static MessageReference	MessageReference.Factory.createReference(Message encode, Queue queue)
MessageReference	ServerMessage.createReference(Queue queue) Deprecated.
MessageReference	Queue.getReference(long id)
MessageReference	ServerConsumer.removeReferenceByID(long messageID)
MessageReference	Queue.removeReferenceWithID(long id)
MessageReference	ScheduledDeliveryHandler.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)
List<MessageReference>	Consumer.getDeliveringMessages()
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>	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, ServerConsumer consumer)
void	Queue.acknowledge(MessageReference ref, ServerConsumer consumer)
void	Queue.acknowledge(Transaction tx, MessageReference ref)
void	Queue.acknowledge(Transaction tx, MessageReference ref, AckReason reason, ServerConsumer consumer)
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)
Pair<Boolean,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)
default void	Queue.errorProcessing(Consumer consumer, Throwable t, MessageReference messageReference)
default void	Consumer.errorProcessing(Throwable e, MessageReference reference)
void	Queue.expire(MessageReference ref)
void	Queue.expire(MessageReference ref, ServerConsumer consumer)
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) Deprecated.
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, AckReason reason)
void	Consumer.proceedDeliver(MessageReference reference) This will proceed with the actual delivery.
void	Queue.reacknowledge(Transaction tx, MessageReference ref)
void	Queue.referenceHandled(MessageReference ref)
void	Queue.reload(MessageReference ref)
boolean	Queue.sendToDeadLetterAddress(Transaction tx, MessageReference ref)
void	ServerMessage.setOriginalHeaders(ServerMessage other, MessageReference originalReference, boolean expiry) Deprecated.

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)
void	MessageReference.onDelivery(Consumer<? super MessageReference> callback) This is to be used in cases where a message delivery happens on an executor.
void	RoutingContext.processReferences(List<MessageReference> refs, boolean direct)

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	GroupFirstMessageReference This MessageReference should only be created the first time a group is assigned to a consumer, it allows us to make a copy of the message to add the property safely as a delivery semantic, without affecting the underlying message.
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
LinkedListIterator<MessageReference>	ServerConsumerImpl.BrowserDeliverer.iterator

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

Modifier and Type	Method and Description
MessageReference	GroupFirstMessageReference.copy(Queue queue)
MessageReference	MessageReferenceImpl.copy(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)
List<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	LastValueQueue.acknowledge(MessageReference ref, AckReason reason, ServerConsumer consumer)
void	QueueImpl.acknowledge(MessageReference ref, AckReason reason, ServerConsumer consumer)
void	QueueImpl.acknowledge(MessageReference ref, ServerConsumer consumer)
void	QueueImpl.acknowledge(Transaction tx, MessageReference ref)
void	QueueImpl.acknowledge(Transaction tx, MessageReference ref, AckReason reason, ServerConsumer consumer)
void	LastValueQueue.addHead(MessageReference ref, boolean scheduling)
void	QueueImpl.addHead(MessageReference ref, boolean scheduling)
void	ScheduledDeliveryHandlerImpl.addInPlace(long deliveryTime, MessageReference ref, boolean tail)
void	QueueImpl.addTail(MessageReference ref)
void	LastValueQueue.addTail(MessageReference ref, boolean direct)
void	QueueImpl.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)
Pair<Boolean,Boolean>	QueueImpl.checkRedelivery(MessageReference reference, long timeBase, boolean ignoreRedeliveryDelay)
void	QueueImpl.decDelivering(MessageReference reference)
void	QueuePendingMessageMetrics.decrementMetrics(MessageReference reference)
void	QueueImpl.errorProcessing(Consumer consumer, Throwable t, MessageReference reference) This will print errors and decide what to do with the errored consumer from the protocol layer.
void	ServerConsumerImpl.errorProcessing(Throwable e, MessageReference deliveryObject)
void	QueueImpl.expire(MessageReference ref)
void	QueueImpl.expire(MessageReference ref, ServerConsumer consumer)
HandleStatus	ServerConsumerImpl.handle(MessageReference ref)
void	QueuePendingMessageMetrics.incrementMetrics(MessageReference reference)
void	QueueImpl.postAcknowledge(MessageReference ref, AckReason reason)
void	ServerConsumerImpl.proceedDeliver(MessageReference reference)
void	QueueImpl.reacknowledge(Transaction tx, MessageReference ref)
protected void	QueueImpl.refAdded(MessageReference ref)
void	QueueImpl.referenceHandled(MessageReference ref)
protected void	LastValueQueue.refRemoved(MessageReference ref)
protected void	QueueImpl.refRemoved(MessageReference ref)
void	QueueImpl.reload(MessageReference ref)
protected void	QueueImpl.removeMessageReference(QueueImpl.ConsumerHolder<? extends Consumer> holder, MessageReference ref)
protected void	RefsOperation.rollbackRedelivery(Transaction tx, MessageReference ref, long timeBase, Map<QueueImpl,LinkedList<MessageReference>> queueMap)
protected boolean	QueueImpl.scheduleIfPossible(MessageReference ref)
boolean	QueueImpl.sendToDeadLetterAddress(Transaction tx, MessageReference ref)
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	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)
void	GroupFirstMessageReference.onDelivery(Consumer<? super MessageReference> callback)
void	MessageReferenceImpl.onDelivery(Consumer<? super MessageReference> onDelivery)
void	RoutingContextImpl.processReferences(List<MessageReference> refs, boolean direct)
protected void	RefsOperation.rollbackRedelivery(Transaction tx, MessageReference ref, long timeBase, Map<QueueImpl,LinkedList<MessageReference>> queueMap)

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

Constructor and Description
GroupFirstMessageReference(SimpleString key, MessageReference messageReference)

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.server.plugin

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

Modifier and Type	Method and Description
default void	ActiveMQServerBridgePlugin.afterAcknowledgeBridge(Bridge bridge, MessageReference ref) Called after delivered message over this bridge has been acknowledged by the remote broker
default void	ActiveMQServerMessagePlugin.afterDeliver(MessageReference reference) Deprecated. use ActiveMQServerMessagePlugin.afterDeliver(ServerConsumer, MessageReference)
default void	ActiveMQServerMessagePlugin.afterDeliver(ServerConsumer consumer, MessageReference reference) After a message is delivered to a client consumer
default void	ActiveMQServerBridgePlugin.afterDeliverBridge(Bridge bridge, MessageReference ref, HandleStatus status) Called immediately after a bridge delivers a message but before the message is acknowledged
default void	ActiveMQServerMessagePlugin.beforeDeliver(MessageReference reference) Deprecated. use throws ActiveMQException ActiveMQServerMessagePlugin.beforeDeliver(ServerConsumer, MessageReference)
default void	ActiveMQServerMessagePlugin.beforeDeliver(ServerConsumer consumer, MessageReference reference) Before a message is delivered to a client consumer
default void	ActiveMQServerBridgePlugin.beforeDeliverBridge(Bridge bridge, MessageReference ref) Called immediately before a bridge delivers a message
default void	ActiveMQServerMessagePlugin.messageAcknowledged(MessageReference ref, AckReason reason) Deprecated. use ActiveMQServerMessagePlugin.messageAcknowledged(MessageReference, AckReason, ServerConsumer)
default void	ActiveMQServerMessagePlugin.messageAcknowledged(MessageReference ref, AckReason reason, ServerConsumer consumer) A message has been acknowledged
default void	ActiveMQServerMessagePlugin.messageExpired(MessageReference message, SimpleString messageExpiryAddress) Deprecated. use ActiveMQServerMessagePlugin.messageExpired(MessageReference, SimpleString, ServerConsumer)
default void	ActiveMQServerMessagePlugin.messageExpired(MessageReference message, SimpleString messageExpiryAddress, ServerConsumer consumer) A message has been expired

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

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

Modifier and Type	Method and Description
void	LoggingActiveMQServerPlugin.afterDeliver(ServerConsumer consumer, MessageReference reference) After a message is delivered to a client consumer
void	NotificationActiveMQServerPlugin.afterDeliver(ServerConsumer consumer, MessageReference reference)
void	LoggingActiveMQServerPluginLogger.afterDeliverDetails(String messageID, SimpleString queueAddress, SimpleString queueName, String consumerSessionID, long consumerID, MessageReference reference, ServerConsumer consumer)
void	LoggingActiveMQServerPlugin.beforeDeliver(ServerConsumer consumer, MessageReference reference) Before a message is delivered to a client consumer
void	LoggingActiveMQServerPluginLogger.beforeDeliver(ServerConsumer consumer, MessageReference reference)
void	LoggingActiveMQServerPlugin.messageAcknowledged(MessageReference ref, AckReason reason, ServerConsumer consumer) A message has been acknowledged
void	LoggingActiveMQServerPluginLogger.messageAcknowledgedDetails(MessageReference ref, AckReason reason)
void	LoggingActiveMQServerPluginLogger.messageExpired(MessageReference message, SimpleString messageExpiryAddress)
void	LoggingActiveMQServerPlugin.messageExpired(MessageReference message, SimpleString messageExpiryAddress, ServerConsumer consumer)
void	NotificationActiveMQServerPlugin.messageExpired(MessageReference message, SimpleString messageExpiryAddress, ServerConsumer consumer)

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

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

Modifier and Type	Method and Description
MessageReference	ServerMessageImpl.createReference(Queue queue) Deprecated.

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

Modifier and Type	Method and Description
ServerMessage	ServerMessageImpl.makeCopyForExpiryOrDLA(long newID, MessageReference originalReference, boolean expiry, boolean copyOriginalHeaders) Deprecated.
void	ServerMessageImpl.setOriginalHeaders(ServerMessage otherServerMessage, MessageReference originalReference, boolean expiry) Deprecated.

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>	TransactionOperation.getListOnConsumer(long consumerID)
List<MessageReference>	TransactionOperationAbstract.getListOnConsumer(long consumerID)
List<MessageReference>	TransactionOperation.getRelatedMessageReferences()
List<MessageReference>	TransactionOperationAbstract.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, Message message, ServerConsumer consumerID, long bodySize, int deliveryCount)
int	SessionCallback.sendMessage(MessageReference ref, Message 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.