Uses of Interface
org.apache.activemq.artemis.api.core.Message

Packages that use Message

Package	Description
org.apache.activemq.artemis.api.core
org.apache.activemq.artemis.api.core.client
org.apache.activemq.artemis.api.core.management
org.apache.activemq.artemis.cli.commands.tools.xml
org.apache.activemq.artemis.core.buffers.impl
org.apache.activemq.artemis.core.client.impl
org.apache.activemq.artemis.core.filter
org.apache.activemq.artemis.core.filter.impl
org.apache.activemq.artemis.core.message.impl
org.apache.activemq.artemis.core.message.openmbean
org.apache.activemq.artemis.core.paging
org.apache.activemq.artemis.core.paging.cursor
org.apache.activemq.artemis.core.paging.impl
org.apache.activemq.artemis.core.persistence
org.apache.activemq.artemis.core.persistence.impl.journal
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.protocol.core.impl.wireformat
org.apache.activemq.artemis.core.protocol.hornetq.util
org.apache.activemq.artemis.core.replication
org.apache.activemq.artemis.core.server
org.apache.activemq.artemis.core.server.cluster
org.apache.activemq.artemis.core.server.cluster.impl
org.apache.activemq.artemis.core.server.impl
org.apache.activemq.artemis.core.server.management
org.apache.activemq.artemis.core.server.management.impl
org.apache.activemq.artemis.core.server.mirror
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.core.transaction.impl
org.apache.activemq.artemis.jms.transaction
org.apache.activemq.artemis.reader
org.apache.activemq.artemis.spi.core.protocol
org.apache.activemq.artemis.spi.core.remoting

Uses of Message in org.apache.activemq.artemis.api.core

Subinterfaces of Message in org.apache.activemq.artemis.api.core

Modifier and Type	Interface	Description
interface	ICoreMessage	This interface is only to determine the API of methods required for Core Messages

Methods in org.apache.activemq.artemis.api.core that return Message

Modifier and Type	Method	Description
Message	Message.copy()	It will generate a new instance of the message encode, being a deep copy, new properties, new everything
Message	Message.copy(long newID)	It will generate a new instance of the message encode, being a deep copy, new properties, new everything
default Message	Message.copy(long newID, boolean isExpiryOrDLQ)	It will generate a new instance of the message encode, being a deep copy, new properties, new everything
Message	Message.putBooleanProperty(String key, boolean value)
Message	Message.putBooleanProperty(SimpleString key, boolean value)
Message	Message.putByteProperty(String key, byte value)
Message	Message.putByteProperty(SimpleString key, byte value)
Message	Message.putBytesProperty(String key, byte[] value)
Message	Message.putBytesProperty(SimpleString key, byte[] value)
Message	Message.putCharProperty(String key, char value)
Message	Message.putCharProperty(SimpleString key, char value)
Message	Message.putDoubleProperty(String key, double value)
Message	Message.putDoubleProperty(SimpleString key, double value)
default Message	Message.putExtraBytesProperty(SimpleString key, byte[] value)
Message	Message.putFloatProperty(String key, float value)
Message	Message.putFloatProperty(SimpleString key, float value)
Message	Message.putIntProperty(String key, int value)
Message	Message.putIntProperty(SimpleString key, int value)
Message	Message.putLongProperty(String key, long value)
Message	Message.putLongProperty(SimpleString key, long value)
Message	Message.putObjectProperty(String key, Object value)
Message	Message.putObjectProperty(SimpleString key, Object value)
Message	Message.putShortProperty(String key, short value)
Message	Message.putShortProperty(SimpleString key, short value)
Message	Message.putStringProperty(String key, String value)	Puts a String property in this message.
Message	Message.putStringProperty(SimpleString key, String value)
Message	Message.putStringProperty(SimpleString key, SimpleString value)
Message	Message.setAddress(String address)	Look at setAddress(SimpleString) for the doc.
Message	Message.setAddress(SimpleString address)	This will set the address on CoreMessage.
default Message	Message.setAnnotation(SimpleString key, Object value)	Callers must call reencode() in order to be sent to clients
default Message	Message.setBrokerProperty(SimpleString key, Object value)	To be called by the broker on ocasions such as DLQ and expiry.
Message	ICoreMessage.setBuffer(io.netty.buffer.ByteBuf buffer)	The buffer will belong to this message, until release is called.
default Message	Message.setConnectionID(String connectionID)
default Message	Message.setCorrelationID(Object correlationID)
Message	Message.setDurable(boolean durable)	Sets whether this message is durable or not.
Message	Message.setExpiration(long expiration)	Sets the expiration of this message.
default Message	Message.setGroupID(String groupID)
default Message	Message.setGroupID(SimpleString groupID)
default Message	Message.setGroupSequence(int sequence)
default Message	Message.setIngressTimestamp()
default Message	Message.setLastValueProperty(SimpleString lastValueName)
Message	Message.setMessageID(long id)
Message	Message.setPriority(byte priority)	Sets the message priority.
Message	Message.setReplyTo(SimpleString address)
default Message	Message.setRoutingType(RoutingType routingType)
default Message	Message.setScheduledDeliveryTime(Long time)
Message	Message.setTimestamp(long timestamp)
default Message	Message.setType(byte type)	Deprecated. do not use this, use through ICoreMessage or ClientMessage
Message	Message.setUserID(Object userID)
default Message	Message.setValidatedUserID(String validatedUserID)

Methods in org.apache.activemq.artemis.api.core that return types with arguments of type Message

Modifier and Type	Method	Description
Persister<Message>	Message.getPersister()

Methods in org.apache.activemq.artemis.api.core with parameters of type Message

Modifier and Type	Method	Description
void	RefCountMessageListener.durableDown(Message message, int durableCount)
void	RefCountMessageListener.durableUp(Message message, int durableCount)
void	ICoreMessage.moveHeadersAndProperties(Message msg)	Used on large messages treatment.
void	RefCountMessageListener.refDown(Message message, int nonDurableCoun)
default void	Message.referenceOriginalMessage(Message original, SimpleString originalQueue)
void	RefCountMessageListener.refUp(Message message, int nonDurableCoun)
default void	RefCountMessageListener.usageDown(Message message, int usageCount)
default void	RefCountMessageListener.usageUp(Message message, int usageCount)

Uses of Message in org.apache.activemq.artemis.api.core.client

Subinterfaces of Message in org.apache.activemq.artemis.api.core.client

Modifier and Type	Interface	Description
interface	ClientMessage	A ClientMessage represents a message sent and/or received by ActiveMQ Artemis.

Methods in org.apache.activemq.artemis.api.core.client with parameters of type Message

Modifier and Type	Method	Description
void	ClientProducer.send(String address, Message message)	Sends a message to the specified address instead of the ClientProducer's address.
void	ClientProducer.send(Message message)	Sends a message to an address.
void	ClientProducer.send(Message message, SendAcknowledgementHandler handler)	Sends a message to the specified address instead of the ClientProducer's address.
void	ClientProducer.send(SimpleString address, Message message)	Sends a message to the specified address instead of the ClientProducer's address.
void	ClientProducer.send(SimpleString address, Message message, SendAcknowledgementHandler handler)	Sends a message to the specified address instead of the ClientProducer's address.
void	SendAcknowledgementHandler.sendAcknowledged(Message message)	Notifies the client that a message sent asynchronously has been received by the server.
default void	SendAcknowledgementHandler.sendFailed(Message message, Exception e)

Uses of Message in org.apache.activemq.artemis.api.core.management

Methods in org.apache.activemq.artemis.api.core.management with parameters of type Message

Modifier and Type	Method	Description
static boolean	ManagementHelper.hasOperationSucceeded(Message message)	Returns whether the invocation of the management operation on the server resource succeeded.
static boolean	ManagementHelper.isAttributesResult(Message message)	Returns whether the JMS message corresponds to the result of a management attribute value.
static boolean	ManagementHelper.isOperationResult(Message message)	Returns whether the JMS message corresponds to the result of a management operation invocation.
static Object[]	ManagementHelper.retrieveOperationParameters(Message message)	Used by ActiveMQ Artemis management service.

Uses of Message in org.apache.activemq.artemis.cli.commands.tools.xml

Fields in org.apache.activemq.artemis.cli.commands.tools.xml declared as Message

Modifier and Type	Field	Description
Message	XMLMessageImporter.MessageInfo.message

Methods in org.apache.activemq.artemis.cli.commands.tools.xml with parameters of type Message

Modifier and Type	Method	Description
static String	XmlDataExporterUtil.encodeMessageBodyBase64(Message message)	Base64 encode a ServerMessage body into the proper XML format
void	XMLMessageExporter.printLargeMessageBody(Message message)
void	XMLMessageExporter.printMessageBody(Message message, boolean encodeTextMessageUTF8)
void	XMLMessageExporter.printMessageProperties(Message message)

Uses of Message in org.apache.activemq.artemis.core.buffers.impl

Methods in org.apache.activemq.artemis.core.buffers.impl with parameters of type Message

Modifier and Type	Method	Description
void	ResetLimitWrappedActiveMQBuffer.setMessage(Message message)	We need to turn of notifications of body changes on reset on the server side when dealing with AMQP conversions, for that reason this method will set the message to null here

Constructors in org.apache.activemq.artemis.core.buffers.impl with parameters of type Message

Constructor	Description
ResetLimitWrappedActiveMQBuffer(int limit, io.netty.buffer.ByteBuf buffer, Message message)
ResetLimitWrappedActiveMQBuffer(int limit, ActiveMQBuffer buffer, Message message)

Uses of Message in org.apache.activemq.artemis.core.client.impl

Subinterfaces of Message in org.apache.activemq.artemis.core.client.impl

Modifier and Type	Interface	Description
interface	ClientLargeMessageInternal
interface	ClientMessageInternal

Classes in org.apache.activemq.artemis.core.client.impl that implement Message

Modifier and Type	Class	Description
class	ClientLargeMessageImpl	ClientLargeMessageImpl is only created when receiving large messages.
class	ClientMessageImpl	A ClientMessageImpl

Methods in org.apache.activemq.artemis.core.client.impl that return Message

Modifier and Type	Method	Description
Message	ClientMessageImpl.copy()

Methods in org.apache.activemq.artemis.core.client.impl with parameters of type Message

Modifier and Type	Method	Description
void	ClientSessionImpl.acknowledge(ClientConsumer consumer, Message message)	Acknowledges all messages received by the consumer so far.
void	ClientSessionInternal.acknowledge(ClientConsumer consumer, Message message)
void	ClientSessionImpl.expire(ClientConsumer consumer, Message message)
void	ClientSessionInternal.expire(ClientConsumer consumer, Message message)
void	ClientSessionImpl.individualAcknowledge(ClientConsumer consumer, Message message)
void	ClientSessionInternal.individualAcknowledge(ClientConsumer consumer, Message message)
void	ClientSessionImpl.scheduleConfirmation(SendAcknowledgementHandler handler, Message message)
void	ClientSessionInternal.scheduleConfirmation(SendAcknowledgementHandler handler, Message message)
void	ClientProducerImpl.send(String address1, Message message)
void	ClientProducerImpl.send(Message msg)
void	ClientProducerImpl.send(Message message, SendAcknowledgementHandler handler)
void	ClientProducerImpl.send(SimpleString address1, Message msg)
void	ClientProducerImpl.send(SimpleString address1, Message message, SendAcknowledgementHandler handler)
void	SendAcknowledgementHandlerWrapper.sendAcknowledged(Message message)
void	SendAcknowledgementHandlerWrapper.sendFailed(Message message, Exception e)
void	ClientSessionImpl.setAddress(Message message, SimpleString address)
void	ClientSessionInternal.setAddress(Message message, SimpleString address)	This will set the address at the message

Uses of Message in org.apache.activemq.artemis.core.filter

Methods in org.apache.activemq.artemis.core.filter with parameters of type Message

Modifier and Type	Method	Description
boolean	Filter.match(Message message)

Uses of Message in org.apache.activemq.artemis.core.filter.impl

Methods in org.apache.activemq.artemis.core.filter.impl with parameters of type Message

Modifier and Type	Method	Description
boolean	FilterImpl.match(Message message)

Uses of Message in org.apache.activemq.artemis.core.message.impl

Subinterfaces of Message in org.apache.activemq.artemis.core.message.impl

Modifier and Type	Interface	Description
interface	MessageInternal	Deprecated.

Classes in org.apache.activemq.artemis.core.message.impl that implement Message

Modifier and Type	Class	Description
class	CoreMessage	Note: you shouldn't change properties using multi-threads.
class	MessageInternalImpl	Deprecated.

Methods in org.apache.activemq.artemis.core.message.impl that return Message

Modifier and Type	Method	Description
Message	CoreMessage.copy()
Message	CoreMessage.copy(long newID)
Message	MessageInternalImpl.copy()	Deprecated. It will generate a new instance of the message encode, being a deep copy, new properties, new everything
Message	MessageInternalImpl.copy(long newID)	Deprecated. It will generate a new instance of the message encode, being a deep copy, new properties, new everything
Message	MessageInternalImpl.copy(long newID, boolean isDLQorExpiry)	Deprecated.
Message	CoreMessagePersister.decode(ActiveMQBuffer buffer, Message record, CoreMessageObjectPools pool)
Message	MessageInternalImpl.putBooleanProperty(String key, boolean value)	Deprecated.
Message	MessageInternalImpl.putBooleanProperty(SimpleString key, boolean value)	Deprecated.
Message	MessageInternalImpl.putByteProperty(String key, byte value)	Deprecated.
Message	MessageInternalImpl.putByteProperty(SimpleString key, byte value)	Deprecated.
Message	MessageInternalImpl.putBytesProperty(String key, byte[] value)	Deprecated.
Message	MessageInternalImpl.putBytesProperty(SimpleString key, byte[] value)	Deprecated.
Message	MessageInternalImpl.putCharProperty(String key, char value)	Deprecated.
Message	MessageInternalImpl.putCharProperty(SimpleString key, char value)	Deprecated.
Message	MessageInternalImpl.putDoubleProperty(String key, double value)	Deprecated.
Message	MessageInternalImpl.putDoubleProperty(SimpleString key, double value)	Deprecated.
Message	MessageInternalImpl.putFloatProperty(String key, float value)	Deprecated.
Message	MessageInternalImpl.putFloatProperty(SimpleString key, float value)	Deprecated.
Message	MessageInternalImpl.putIntProperty(String key, int value)	Deprecated.
Message	MessageInternalImpl.putIntProperty(SimpleString key, int value)	Deprecated.
Message	MessageInternalImpl.putLongProperty(String key, long value)	Deprecated.
Message	MessageInternalImpl.putLongProperty(SimpleString key, long value)	Deprecated.
Message	MessageInternalImpl.putObjectProperty(String key, Object value)	Deprecated.
Message	MessageInternalImpl.putObjectProperty(SimpleString key, Object value)	Deprecated.
Message	MessageInternalImpl.putShortProperty(String key, short value)	Deprecated.
Message	MessageInternalImpl.putShortProperty(SimpleString key, short value)	Deprecated.
Message	MessageInternalImpl.putStringProperty(String key, String value)	Deprecated. Puts a String property in this message.
Message	MessageInternalImpl.putStringProperty(SimpleString key, String value)	Deprecated.
Message	MessageInternalImpl.putStringProperty(SimpleString key, SimpleString value)	Deprecated.
Message	MessageInternalImpl.setAddress(String address)	Deprecated.
Message	MessageInternalImpl.setAddress(SimpleString address)	Deprecated.
Message	MessageInternalImpl.setBuffer(io.netty.buffer.ByteBuf buffer)	Deprecated. The buffer will belong to this message, until release is called.
Message	CoreMessage.setCorrelationID(Object correlationID)
Message	MessageInternalImpl.setDurable(boolean durable)	Deprecated. Sets whether this message is durable or not.
Message	MessageInternalImpl.setExpiration(long expiration)	Deprecated. Sets the expiration of this message.
Message	CoreMessage.setLastValueProperty(SimpleString lastValueName)
Message	MessageInternalImpl.setMessageID(long id)	Deprecated.
Message	MessageInternalImpl.setPriority(byte priority)	Deprecated. Sets the message priority.
Message	MessageInternalImpl.setReplyTo(SimpleString address)	Deprecated.
Message	CoreMessage.setRoutingType(RoutingType routingType)
Message	MessageInternalImpl.setTimestamp(long timestamp)	Deprecated.
Message	MessageInternalImpl.setUserID(Object userID)	Deprecated.

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

Modifier and Type	Method	Description
Persister<Message>	CoreMessage.getPersister()
Persister<Message>	MessageInternalImpl.getPersister()	Deprecated.

Methods in org.apache.activemq.artemis.core.message.impl with parameters of type Message

Modifier and Type	Method	Description
Message	CoreMessagePersister.decode(ActiveMQBuffer buffer, Message record, CoreMessageObjectPools pool)
void	CoreMessagePersister.encode(ActiveMQBuffer buffer, Message record)	Sub classes must add the first short as the protocol-id
int	CoreMessagePersister.getEncodeSize(Message record)
void	CoreMessage.moveHeadersAndProperties(Message msg)

Uses of Message in org.apache.activemq.artemis.core.message.openmbean

Classes in org.apache.activemq.artemis.core.message.openmbean with type parameters of type Message

Modifier and Type	Class	Description
class	MessageOpenTypeFactory<M extends Message>

Uses of Message in org.apache.activemq.artemis.core.paging

Methods in org.apache.activemq.artemis.core.paging that return Message

Modifier and Type	Method	Description
Message	PagedMessage.getMessage()

Methods in org.apache.activemq.artemis.core.paging with parameters of type Message

Modifier and Type	Method	Description
boolean	PagingStore.page(Message message, Transaction tx, RouteContextList listCtx)	Write message to page if we are paging.

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

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

Modifier and Type	Method	Description
Message	PagedReferenceImpl.getMessage()

Uses of Message in org.apache.activemq.artemis.core.paging.impl

Methods in org.apache.activemq.artemis.core.paging.impl that return Message

Modifier and Type	Method	Description
Message	PagedMessageImpl.getMessage()

Methods in org.apache.activemq.artemis.core.paging.impl with parameters of type Message

Modifier and Type	Method	Description
void	PagingStoreImpl.durableDown(Message message, int durableCount)
void	PagingStoreImpl.durableUp(Message message, int durableCount)
boolean	PagingStoreImpl.page(Message message, Transaction tx, RouteContextList listCtx)
void	PagingStoreImpl.refDown(Message message, int count)
void	PagingStoreImpl.refUp(Message message, int count)

Constructors in org.apache.activemq.artemis.core.paging.impl with parameters of type Message

Constructor	Description
PagedMessageImpl(Message message, long[] queueIDs)
PagedMessageImpl(Message message, long[] queueIDs, long transactionID)

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

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

Modifier and Type	Method	Description
boolean	StorageManager.addToPage(PagingStore store, Message msg, Transaction tx, RouteContextList listCtx)	Write message to page if we are paging.
LargeServerMessage	StorageManager.createLargeMessage(long id, Message message)	Creates a new LargeMessage with the given id.
void	StorageManager.storeMessage(Message message)
void	StorageManager.storeMessageTransactional(long txID, Message message)

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

Classes in org.apache.activemq.artemis.core.persistence.impl.journal that implement Message

Modifier and Type	Class	Description
class	LargeServerMessageImpl

Methods in org.apache.activemq.artemis.core.persistence.impl.journal that return Message

Modifier and Type	Method	Description
static Message	LargeServerMessageImpl.checkLargeMessage(Message message, StorageManager storageManager)	This will check if a regular message needs to be converted as large message
Message	LargeServerMessageImpl.copy()
Message	LargeServerMessageImpl.copy(long newID)
Message	AddMessageRecord.getMessage()
Message	DescribeJournal.MessageDescribe.getMsg()
Message	LargeServerMessageInSync.setDurable(boolean durable)
Message	LargeServerMessageInSync.setMessageID(long id)
Message	LargeServerMessageImpl.toMessage()

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

Modifier and Type	Method	Description
boolean	AbstractJournalStorageManager.addToPage(PagingStore store, Message msg, Transaction tx, RouteContextList listCtx)
static Message	LargeServerMessageImpl.checkLargeMessage(Message message, StorageManager storageManager)	This will check if a regular message needs to be converted as large message
LargeServerMessage	JournalStorageManager.createLargeMessage(long id, Message message)
void	LargeServerMessageImpl.referenceOriginalMessage(Message original, SimpleString originalQueue)
void	AbstractJournalStorageManager.storeMessage(Message message)
void	AbstractJournalStorageManager.storeMessageTransactional(long txID, Message message)

Constructors in org.apache.activemq.artemis.core.persistence.impl.journal with parameters of type Message

Constructor	Description
AddMessageRecord(Message message)
MessageDescribe(Message msg)

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

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

Modifier and Type	Method	Description
boolean	NullStorageManager.addToPage(PagingStore store, Message msg, Transaction tx, RouteContextList listCtx)
LargeServerMessage	NullStorageManager.createLargeMessage(long id, Message message)
void	NullStorageManager.storeMessage(Message message)
void	NullStorageManager.storeMessageTransactional(long txID, Message message)

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

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

Modifier and Type	Method	Description
Pair<RoutingContext,Message>	PostOffice.redistribute(Message message, Queue originatingQueue, Transaction tx)

Methods in org.apache.activemq.artemis.core.postoffice with parameters of type Message

Modifier and Type	Method	Description
boolean	Binding.isHighAcceptPriority(Message message)
void	PostOffice.processRoute(Message message, RoutingContext context, boolean direct)
boolean	Bindings.redistribute(Message message, Queue originatingQueue, RoutingContext context)
Pair<RoutingContext,Message>	PostOffice.redistribute(Message message, Queue originatingQueue, Transaction tx)
MessageReference	PostOffice.reload(Message message, Queue queue, Transaction tx)
default MessageReference	PostOffice.reroute(Message message, Queue queue, Transaction tx)	Deprecated.
void	Binding.route(Message message, RoutingContext context)
void	Bindings.route(Message message, RoutingContext context)
RoutingStatus	PostOffice.route(Message message, boolean direct)
RoutingStatus	PostOffice.route(Message message, RoutingContext context, boolean direct)
RoutingStatus	PostOffice.route(Message message, RoutingContext context, boolean direct, boolean rejectDuplicates, Binding binding)
RoutingStatus	PostOffice.route(Message message, Transaction tx, boolean direct)
RoutingStatus	PostOffice.route(Message message, Transaction tx, boolean direct, boolean rejectDuplicates)
RoutingStatus	PostOffice.route(Message message, Transaction tx, boolean direct, boolean rejectDuplicates, Binding binding)
void	Binding.routeWithAck(Message message, RoutingContext context)

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

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

Modifier and Type	Method	Description
Pair<RoutingContext,Message>	PostOfficeImpl.redistribute(Message message, Queue originatingQueue, Transaction tx)	The redistribution can't process the route right away as we may be dealing with a large message which will need to be processed on a different thread

Methods in org.apache.activemq.artemis.core.postoffice.impl with parameters of type Message

Modifier and Type	Method	Description
boolean	DivertBinding.isHighAcceptPriority(Message message)
boolean	LocalQueueBinding.isHighAcceptPriority(Message message)
void	PostOfficeImpl.processRoute(Message message, RoutingContext context, boolean direct)
boolean	BindingsImpl.redistribute(Message message, Queue originatingQueue, RoutingContext context)
Pair<RoutingContext,Message>	PostOfficeImpl.redistribute(Message message, Queue originatingQueue, Transaction tx)	The redistribution can't process the route right away as we may be dealing with a large message which will need to be processed on a different thread
MessageReference	PostOfficeImpl.reload(Message message, Queue queue, Transaction tx)
void	BindingsImpl.route(Message message, RoutingContext context)
void	DivertBinding.route(Message message, RoutingContext context)
void	LocalQueueBinding.route(Message message, RoutingContext context)
RoutingStatus	PostOfficeImpl.route(Message message, boolean direct)
RoutingStatus	PostOfficeImpl.route(Message message, RoutingContext context, boolean direct)
RoutingStatus	PostOfficeImpl.route(Message message, RoutingContext context, boolean direct, boolean rejectDuplicates, Binding bindingMove)
RoutingStatus	PostOfficeImpl.route(Message message, Transaction tx, boolean direct)
RoutingStatus	PostOfficeImpl.route(Message message, Transaction tx, boolean direct, boolean rejectDuplicates)
RoutingStatus	PostOfficeImpl.route(Message message, Transaction tx, boolean direct, boolean rejectDuplicates, Binding binding)
void	DivertBinding.routeWithAck(Message message, RoutingContext context)
void	LocalQueueBinding.routeWithAck(Message message, RoutingContext context)
static void	PostOfficeImpl.storeDurableReference(StorageManager storageManager, Message message, Transaction tx, Queue queue, boolean sync)

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

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

Modifier and Type	Method	Description
Persister<Message>[]	CoreProtocolManagerFactory.getPersister()

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

Modifier and Type	Method	Description
void	ActiveMQSessionContext.expireMessage(ClientConsumer consumer, Message message)
int	ActiveMQSessionContext.getCreditsOnSendingFull(Message msgI)
void	ActiveMQSessionContext.sendACK(boolean individual, boolean block, ClientConsumer consumer, Message message)
int	ActiveMQSessionContext.sendInitialChunkOnLargeMessage(Message msgI)
int	CoreSessionCallback.sendLargeMessage(MessageReference ref, Message message, ServerConsumer consumer, long bodySize, int deliveryCount)
int	ActiveMQSessionContext.sendLargeMessageChunk(Message msgI, long messageBodySize, boolean sendBlocking, boolean lastChunk, byte[] chunk, int reconnectID, SendAcknowledgementHandler messageHandler)
int	CoreSessionCallback.sendMessage(MessageReference ref, Message message, ServerConsumer consumer, int deliveryCount)
int	ActiveMQSessionContext.sendServerLargeMessageChunk(Message msgI, long messageBodySize, boolean sendBlocking, boolean lastChunk, byte[] chunk, SendAcknowledgementHandler messageHandler)

Uses of Message in org.apache.activemq.artemis.core.protocol.core.impl.wireformat

Fields in org.apache.activemq.artemis.core.protocol.core.impl.wireformat declared as Message

Modifier and Type	Field	Description
protected Message	SessionSendContinuationMessage.message

Methods in org.apache.activemq.artemis.core.protocol.core.impl.wireformat that return Message

Modifier and Type	Method	Description
Message	SessionReceiveLargeMessage.getLargeMessage()
Message	SessionSendLargeMessage.getLargeMessage()
Message	MessagePacketI.getMessage()
Message	ReplicationPageWriteMessage.getMessage()
Message	SessionReceiveLargeMessage.getMessage()
Message	SessionSendContinuationMessage.getMessage()
Message	SessionSendLargeMessage.getMessage()

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

Modifier and Type	Method	Description
MessagePacket	MessagePacket.replaceMessage(Message message)
MessagePacketI	MessagePacketI.replaceMessage(Message message)
ReplicationPageWriteMessage	ReplicationPageWriteMessage.replaceMessage(Message message)
MessagePacketI	SessionReceiveLargeMessage.replaceMessage(Message message)
MessagePacketI	SessionSendLargeMessage.replaceMessage(Message message)

Constructors in org.apache.activemq.artemis.core.protocol.core.impl.wireformat with parameters of type Message

Constructor	Description
SessionReceiveClientLargeMessage(Message message)
SessionReceiveLargeMessage(long consumerID, Message message, long largeMessageSize, int deliveryCount)
SessionReceiveLargeMessage(Message message)
SessionSendContinuationMessage(byte type, Message message, byte[] body, boolean continues, boolean requiresResponse, long messageBodySize, SendAcknowledgementHandler handler)
SessionSendContinuationMessage(Message message, byte[] body, boolean continues, boolean requiresResponse, long messageBodySize, SendAcknowledgementHandler handler)
SessionSendContinuationMessage_V2(Message message, byte[] body, boolean continues, boolean requiresResponse, long messageBodySize, SendAcknowledgementHandler handler)
SessionSendLargeMessage(Message largeMessage)

Uses of Message in org.apache.activemq.artemis.core.protocol.hornetq.util

Methods in org.apache.activemq.artemis.core.protocol.hornetq.util with parameters of type Message

Modifier and Type	Method	Description
static void	HQPropertiesConverter.replaceAMQProperties(Message message)
static void	HQPropertiesConverter.replaceHQProperties(Message message)

Uses of Message in org.apache.activemq.artemis.core.replication

Methods in org.apache.activemq.artemis.core.replication that return Message

Modifier and Type	Method	Description
Message	ReplicatedLargeMessage.setDurable(boolean b)
Message	ReplicatedLargeMessage.setMessageID(long id)

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

Subinterfaces of Message in org.apache.activemq.artemis.core.server

Modifier and Type	Interface	Description
interface	ServerMessage	Deprecated.

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

Modifier and Type	Method	Description
Message	MessageReference.getMessage()
Message	LargeServerMessage.toMessage()

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

Modifier and Type	Method	Description
static MessageReference	MessageReference.Factory.createReference(Message encode, Queue queue)
RoutingStatus	ServerSession.doSend(Transaction tx, Message msg, SimpleString originalAddress, boolean direct, boolean noAutoCreateQueue)
RoutingStatus	ServerSession.doSend(Transaction tx, Message msg, SimpleString originalAddress, boolean direct, boolean noAutoCreateQueue, RoutingContext routingContext)
void	ActiveMQServerLogger_$logger.duplicateMessageDetected(Message message)
void	ActiveMQServerLogger.duplicateMessageDetected(Message message)
int	Queue.durableDown(Message message)
int	Queue.durableUp(Message message)
SimpleString	RoutingContext.getAddress(Message message)
boolean	Queue.hasMatchingConsumer(Message message)
boolean	RoutingContext.isAlreadyAcked(Message message, Queue queue)
boolean	RoutingContext.isReusable(Message message, int version)
void	ActiveMQServerLogger_$logger.noQueueIdDefined(Message message, Message messageCopy, SimpleString idsHeaderName)
void	ActiveMQServerLogger.noQueueIdDefined(Message message, Message messageCopy, SimpleString idsHeaderName)
void	Bindable.route(Message message, RoutingContext context)
void	Bindable.routeWithAck(Message message, RoutingContext context)
RoutingStatus	ServerSession.send(Message message, boolean direct)
RoutingStatus	ServerSession.send(Message message, boolean direct, boolean noAutoCreateQueue)
RoutingStatus	ServerSession.send(Transaction tx, Message message, boolean direct, boolean noAutoCreateQueue)
RoutingStatus	ServerSession.send(Transaction tx, Message message, boolean direct, boolean noAutoCreateQueue, RoutingContext routingContext)

Uses of Message in org.apache.activemq.artemis.core.server.cluster

Methods in org.apache.activemq.artemis.core.server.cluster that return Message

Modifier and Type	Method	Description
default Message	Transformer.transform(Message message)	Deprecated.

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

Modifier and Type	Method	Description
default Message	Transformer.transform(Message message)	Deprecated.

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

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

Modifier and Type	Method	Description
protected Message	BridgeImpl.beforeForward(Message message, SimpleString forwardingAddress)
protected Message	ClusterConnectionBridge.beforeForward(Message message, SimpleString forwardingAddress)
protected Message	BridgeImpl.beforeForwardingNoCopy(Message message, SimpleString forwardingAddress)	ClusterConnectionBridge already makes a copy of the message.

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

Modifier and Type	Method	Description
protected Message	BridgeImpl.beforeForward(Message message, SimpleString forwardingAddress)
protected Message	ClusterConnectionBridge.beforeForward(Message message, SimpleString forwardingAddress)
protected Message	BridgeImpl.beforeForwardingNoCopy(Message message, SimpleString forwardingAddress)	ClusterConnectionBridge already makes a copy of the message.
boolean	RemoteQueueBindingImpl.isHighAcceptPriority(Message message)
void	RemoteQueueBindingImpl.route(Message message, RoutingContext context)
void	RemoteQueueBindingImpl.routeWithAck(Message message, RoutingContext context)
void	BridgeImpl.sendAcknowledged(Message message)

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

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

Modifier and Type	Method	Description
Message	GroupFirstMessageReference.getMessage()
Message	MessageReferenceImpl.getMessage()

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

Modifier and Type	Method	Description
RoutingStatus	ServerSessionImpl.doSend(Transaction tx, Message msg, SimpleString originalAddress, boolean direct, boolean noAutoCreateQueue)
RoutingStatus	ServerSessionImpl.doSend(Transaction tx, Message msg, SimpleString originalAddress, boolean direct, boolean noAutoCreateQueue, RoutingContext routingContext)
int	QueueImpl.durableDown(Message message)
int	QueueImpl.durableUp(Message message)
SimpleString	RoutingContextImpl.getAddress(Message message)
void	JournalLoader.handlePreparedSendMessage(Message message, Transaction tx, long queueID)
void	PostOfficeJournalLoader.handlePreparedSendMessage(Message message, Transaction tx, long queueID)
boolean	QueueImpl.hasMatchingConsumer(Message message)
boolean	RoutingContextImpl.isAlreadyAcked(Message message, Queue queue)
boolean	RoutingContextImpl.isReusable(Message message, int version)
void	DivertImpl.route(Message message, RoutingContext context)
void	QueueImpl.route(Message message, RoutingContext context)
void	DivertImpl.routeWithAck(Message message, RoutingContext context)
void	QueueImpl.routeWithAck(Message message, RoutingContext context)
RoutingStatus	ServerSessionImpl.send(Message message, boolean direct)
RoutingStatus	ServerSessionImpl.send(Message message, boolean direct, boolean noAutoCreateQueue)
RoutingStatus	ServerSessionImpl.send(Transaction tx, Message msg, boolean direct, boolean noAutoCreateQueue)
RoutingStatus	ServerSessionImpl.send(Transaction tx, Message messageParameter, boolean direct, boolean noAutoCreateQueue, RoutingContext routingContext)

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

Modifier and Type	Method	Description
void	JournalLoader.handleNoMessageReferences(Map<Long,Message> messages)
void	PostOfficeJournalLoader.handleNoMessageReferences(Map<Long,Message> messages)

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

Constructor	Description
MessageReferenceImpl(Message message, Queue queue)

Uses of Message in org.apache.activemq.artemis.core.server.management

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

Modifier and Type	Method	Description
ICoreMessage	ManagementService.handleMessage(Message message)

Uses of Message in org.apache.activemq.artemis.core.server.management.impl

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

Modifier and Type	Method	Description
ICoreMessage	ManagementServiceImpl.handleMessage(Message message)

Uses of Message in org.apache.activemq.artemis.core.server.mirror

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

Modifier and Type	Method	Description
void	MirrorController.sendMessage(Message message, RoutingContext context, List<MessageReference> refs)

Uses of Message in org.apache.activemq.artemis.core.server.plugin

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

Modifier and Type	Method	Description
default void	ActiveMQServerFederationPlugin.afterFederatedQueueConsumerMessageHandled(FederatedQueueConsumer consumer, Message message)	After a federated queue consumer handles a message
default void	ActiveMQServerMessagePlugin.afterMessageRoute(Message message, RoutingContext context, boolean direct, boolean rejectDuplicates, RoutingStatus result)	After a message is routed
default void	ActiveMQServerMessagePlugin.afterSend(ServerSession session, Transaction tx, Message message, boolean direct, boolean noAutoCreateQueue, RoutingStatus result)	After a message is sent
default void	ActiveMQServerMessagePlugin.afterSend(Transaction tx, Message message, boolean direct, boolean noAutoCreateQueue, RoutingStatus result)	Deprecated. use ActiveMQServerMessagePlugin.afterSend(ServerSession, Transaction, Message, boolean, boolean, RoutingStatus)
default void	ActiveMQServerFederationPlugin.beforeFederatedQueueConsumerMessageHandled(FederatedQueueConsumer consumer, Message message)	Before a federated queue consumer handles a message
default void	ActiveMQServerMessagePlugin.beforeMessageRoute(Message message, RoutingContext context, boolean direct, boolean rejectDuplicates)	Before a message is routed
default void	ActiveMQServerMessagePlugin.beforeSend(ServerSession session, Transaction tx, Message message, boolean direct, boolean noAutoCreateQueue)	Before a message is sent
default void	ActiveMQServerMessagePlugin.beforeSend(Transaction tx, Message message, boolean direct, boolean noAutoCreateQueue)	Deprecated. use ActiveMQServerMessagePlugin.beforeSend(ServerSession, Transaction, Message, boolean, boolean)
default void	ActiveMQServerMessagePlugin.onMessageRouteException(Message message, RoutingContext context, boolean direct, boolean rejectDuplicates, Exception e)	When there was an error routing the message
default void	ActiveMQServerMessagePlugin.onSendException(ServerSession session, Transaction tx, Message message, boolean direct, boolean noAutoCreateQueue, Exception e)	When there was an exception sending the message

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

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

Modifier and Type	Method	Description
void	LoggingActiveMQServerPlugin.afterMessageRoute(Message message, RoutingContext context, boolean direct, boolean rejectDuplicates, RoutingStatus result)	After a message is routed
void	LoggingActiveMQServerPluginLogger_$logger.afterMessageRouteDetails(Message message, RoutingContext context, boolean direct, boolean rejectDuplicates)
void	LoggingActiveMQServerPluginLogger.afterMessageRouteDetails(Message message, RoutingContext context, boolean direct, boolean rejectDuplicates)
void	LoggingActiveMQServerPlugin.afterSend(ServerSession session, Transaction tx, Message message, boolean direct, boolean noAutoCreateQueue, RoutingStatus result)	After a message is sent
void	LoggingActiveMQServerPluginLogger_$logger.afterSendDetails(Message message, String result, Transaction tx, String sessionName, String connectionID, boolean direct, boolean noAutoCreateQueue)
void	LoggingActiveMQServerPluginLogger.afterSendDetails(Message message, String result, Transaction tx, String sessionName, String connectionID, boolean direct, boolean noAutoCreateQueue)
void	LoggingActiveMQServerPlugin.beforeMessageRoute(Message message, RoutingContext context, boolean direct, boolean rejectDuplicates)	Before a message is routed
void	LoggingActiveMQServerPluginLogger_$logger.beforeMessageRoute(Message message, RoutingContext context, boolean direct, boolean rejectDuplicates)
void	LoggingActiveMQServerPluginLogger.beforeMessageRoute(Message message, RoutingContext context, boolean direct, boolean rejectDuplicates)
void	LoggingActiveMQServerPlugin.beforeSend(ServerSession session, Transaction tx, Message message, boolean direct, boolean noAutoCreateQueue)	Before a message is sent
void	LoggingActiveMQServerPluginLogger_$logger.beforeSend(Message message, Transaction tx, ServerSession session, boolean direct, boolean noAutoCreateQueue)
void	LoggingActiveMQServerPluginLogger.beforeSend(Message message, Transaction tx, ServerSession session, boolean direct, boolean noAutoCreateQueue)
void	LoggingActiveMQServerPluginLogger_$logger.onMessageRouteErrorDetails(Message message, RoutingContext context, boolean direct, boolean rejectDuplicates)
void	LoggingActiveMQServerPluginLogger.onMessageRouteErrorDetails(Message message, RoutingContext context, boolean direct, boolean rejectDuplicates)
void	LoggingActiveMQServerPlugin.onMessageRouteException(Message message, RoutingContext context, boolean direct, boolean rejectDuplicates, Exception e)
void	LoggingActiveMQServerPluginLogger_$logger.onSendErrorDetails(String messageID, Message message, String sessionName, Transaction tx, ServerSession session, boolean direct, boolean noAutoCreateQueue)
void	LoggingActiveMQServerPluginLogger.onSendErrorDetails(String messageID, Message message, String sessionName, Transaction tx, ServerSession session, boolean direct, boolean noAutoCreateQueue)
void	LoggingActiveMQServerPlugin.onSendException(ServerSession session, Transaction tx, Message message, boolean direct, boolean noAutoCreateQueue, Exception e)

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

Classes in org.apache.activemq.artemis.core.server.transformer that implement Message

Modifier and Type	Class	Description
class	ServerMessageImpl	Deprecated.

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

Modifier and Type	Method	Description
Message	AddHeadersTransformer.transform(Message message)
Message	RegisteredTransformer.transform(Message message)
Message	Transformer.transform(Message message)

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

Modifier and Type	Method	Description
Message	AddHeadersTransformer.transform(Message message)
Message	RegisteredTransformer.transform(Message message)
Message	Transformer.transform(Message message)

Constructors in org.apache.activemq.artemis.core.server.transformer with parameters of type Message

Constructor	Description
ServerMessageImpl(Message message)	Deprecated.

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

Methods in org.apache.activemq.artemis.core.transaction with parameters of type Message

Modifier and Type	Method	Description
abstract Map<String,Object>	TransactionDetail.decodeMessageProperties(Message msg)
abstract String	TransactionDetail.decodeMessageType(Message msg)

Uses of Message in org.apache.activemq.artemis.core.transaction.impl

Methods in org.apache.activemq.artemis.core.transaction.impl with parameters of type Message

Modifier and Type	Method	Description
Map<String,Object>	CoreTransactionDetail.decodeMessageProperties(Message msg)
String	CoreTransactionDetail.decodeMessageType(Message msg)

Uses of Message in org.apache.activemq.artemis.jms.transaction

Methods in org.apache.activemq.artemis.jms.transaction with parameters of type Message

Modifier and Type	Method	Description
Map<String,Object>	JMSTransactionDetail.decodeMessageProperties(Message msg)
String	JMSTransactionDetail.decodeMessageType(Message msg)

Uses of Message in org.apache.activemq.artemis.reader

Methods in org.apache.activemq.artemis.reader with parameters of type Message

Modifier and Type	Method	Description
static void	MessageUtil.clearProperties(Message message)
static int	MessageUtil.getIntProperty(Message message, String name)
static String	MessageUtil.getJMSCorrelationID(Message message)
static byte[]	MessageUtil.getJMSCorrelationIDAsBytes(Message message)
static SimpleString	MessageUtil.getJMSReplyTo(Message message)
static String	MessageUtil.getJMSType(Message message)
static long	MessageUtil.getLongProperty(Message message, String name)
static Object	MessageUtil.getObjectProperty(Message message, String name)
static Set<String>	MessageUtil.getPropertyNames(Message message)
static String	MessageUtil.getStringProperty(Message message, String name)
static boolean	MessageUtil.propertyExists(Message message, String name)
static void	MessageUtil.setIntProperty(Message message, String name, int value)
static void	MessageUtil.setJMSCorrelationID(Message message, String correlationID)
static void	MessageUtil.setJMSCorrelationIDAsBytes(Message message, byte[] correlationID)
static void	MessageUtil.setJMSReplyTo(Message message, String dest)
static void	MessageUtil.setJMSReplyTo(Message message, SimpleString dest)
static void	MessageUtil.setJMSType(Message message, String type)
static void	MessageUtil.setLongProperty(Message message, String name, long value)
static void	MessageUtil.setObjectProperty(Message message, String name, Object value)
static void	MessageUtil.setStringProperty(Message message, String name, String value)

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

Classes in org.apache.activemq.artemis.spi.core.protocol with type parameters of type Message

Modifier and Type	Interface	Description
interface	MessageConverter<ProtocolMessage extends Message>

Methods in org.apache.activemq.artemis.spi.core.protocol that return Message

Modifier and Type	Method	Description
Message	MessagePersister.decode(ActiveMQBuffer buffer, Message record, CoreMessageObjectPools pools)
Message	MessagePersister.decode(ActiveMQBuffer buffer, Message record, CoreMessageObjectPools pools, StorageManager storageManager)
static Message	EmbedMessageUtil.extractEmbedded(ICoreMessage message, StorageManager storageManager)

Methods in org.apache.activemq.artemis.spi.core.protocol that return types with arguments of type Message

Modifier and Type	Method	Description
default Persister<Message>[]	ProtocolManagerFactory.getPersister()

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

Modifier and Type	Method	Description
Message	MessagePersister.decode(ActiveMQBuffer buffer, Message record, CoreMessageObjectPools pools)
Message	MessagePersister.decode(ActiveMQBuffer buffer, Message record, CoreMessageObjectPools pools, StorageManager storageManager)
static ICoreMessage	EmbedMessageUtil.embedAsCoreMessage(Message source)
void	MessagePersister.encode(ActiveMQBuffer buffer, Message record)	Sub classes must add the first short as the protocol-id
int	MessagePersister.getEncodeSize(Message record)
int	SessionCallback.sendLargeMessage(MessageReference reference, Message message, ServerConsumer consumerID, long bodySize, int deliveryCount)
int	SessionCallback.sendMessage(MessageReference ref, Message message, ServerConsumer consumerID, int deliveryCount)

Method parameters in org.apache.activemq.artemis.spi.core.protocol with type arguments of type Message

Modifier and Type	Method	Description
static void	MessagePersister.registerPersister(Persister<Message> persister)

Uses of Message in org.apache.activemq.artemis.spi.core.remoting

Methods in org.apache.activemq.artemis.spi.core.remoting with parameters of type Message

Modifier and Type	Method	Description
abstract void	SessionContext.expireMessage(ClientConsumer consumer, Message message)
abstract int	SessionContext.getCreditsOnSendingFull(Message msgI)
abstract void	SessionContext.sendACK(boolean individual, boolean block, ClientConsumer consumer, Message message)
abstract int	SessionContext.sendInitialChunkOnLargeMessage(Message msgI)	it should return the number of credits (or bytes) used to send this packet
abstract int	SessionContext.sendLargeMessageChunk(Message msgI, long messageBodySize, boolean sendBlocking, boolean lastChunk, byte[] chunk, int reconnectID, SendAcknowledgementHandler messageHandler)
abstract int	SessionContext.sendServerLargeMessageChunk(Message msgI, long messageBodySize, boolean sendBlocking, boolean lastChunk, byte[] chunk, SendAcknowledgementHandler messageHandler)