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.core.server.plugin
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)	Callers must call reencode() in order to be sent to clients
Message	Message.putBooleanProperty(SimpleString key, boolean value)	Callers must call reencode() in order to be sent to clients
Message	Message.putByteProperty(String key, byte value)	Callers must call reencode() in order to be sent to clients
Message	Message.putByteProperty(SimpleString key, byte value)	Callers must call reencode() in order to be sent to clients
Message	Message.putBytesProperty(String key, byte[] value)	Callers must call reencode() in order to be sent to clients
Message	Message.putBytesProperty(SimpleString key, byte[] value)	Callers must call reencode() in order to be sent to clients
Message	Message.putCharProperty(String key, char value)	Callers must call reencode() in order to be sent to clients
Message	Message.putCharProperty(SimpleString key, char value)	Callers must call reencode() in order to be sent to clients
Message	Message.putDoubleProperty(String key, double value)	Callers must call reencode() in order to be sent to clients
Message	Message.putDoubleProperty(SimpleString key, double value)	Callers must call reencode() in order to be sent to clients
default Message	Message.putExtraBytesProperty(SimpleString key, byte[] value)
Message	Message.putFloatProperty(String key, float value)	Callers must call reencode() in order to be sent to clients
Message	Message.putFloatProperty(SimpleString key, float value)	Callers must call reencode() in order to be sent to clients
Message	Message.putIntProperty(String key, int value)	Callers must call reencode() in order to be sent to clients
Message	Message.putIntProperty(SimpleString key, int value)	Callers must call reencode() in order to be sent to clients
Message	Message.putLongProperty(String key, long value)	Callers must call reencode() in order to be sent to clients
Message	Message.putLongProperty(SimpleString key, long value)	Callers must call reencode() in order to be sent to clients
Message	Message.putObjectProperty(String key, Object value)	Callers must call reencode() in order to be sent to clients
Message	Message.putObjectProperty(SimpleString key, Object value)	Callers must call reencode() in order to be sent to clients
Message	Message.putShortProperty(String key, short value)	Callers must call reencode() in order to be sent to clients
Message	Message.putShortProperty(SimpleString key, short value)	Callers must call reencode() in order to be sent to clients
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
org.apache.activemq.artemis.core.persistence.Persister<Message>	Message.getPersister()

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

Modifier and Type	Method	Description
static void	RefCountMessage.deferredDebug(Message message, String debugMessage, Object... args)
void	RefCountMessageListener.durableDown(Message message, int durableCount)
void	RefCountMessageListener.durableUp(Message message, int durableCount)
void	ICoreMessage.moveHeadersAndProperties(Message msg)	Used on large messages treatment. this method is used to transfer properties from a temporary CoreMessage to a definitive one.
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. specified in ClientSession.createProducer(String) or similar methods.
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.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(org.apache.activemq.artemis.core.server.federation.FederatedQueueConsumer consumer, Message message)	After a federated queue consumer handles a message
default void	ActiveMQServerMessagePlugin.afterMessageRoute(Message message, org.apache.activemq.artemis.core.server.RoutingContext context, boolean direct, boolean rejectDuplicates, org.apache.activemq.artemis.core.postoffice.RoutingStatus result)	After a message is routed
default void	ActiveMQServerMessagePlugin.afterSend(org.apache.activemq.artemis.core.server.ServerSession session, org.apache.activemq.artemis.core.transaction.Transaction tx, Message message, boolean direct, boolean noAutoCreateQueue, org.apache.activemq.artemis.core.postoffice.RoutingStatus result)	After a message is sent
default void	ActiveMQServerMessagePlugin.afterSend(org.apache.activemq.artemis.core.transaction.Transaction tx, Message message, boolean direct, boolean noAutoCreateQueue, org.apache.activemq.artemis.core.postoffice.RoutingStatus result)	Deprecated. use ActiveMQServerMessagePlugin.afterSend(ServerSession, Transaction, Message, boolean, boolean, RoutingStatus)
default void	ActiveMQServerFederationPlugin.beforeFederatedQueueConsumerMessageHandled(org.apache.activemq.artemis.core.server.federation.FederatedQueueConsumer consumer, Message message)	Before a federated queue consumer handles a message
default void	ActiveMQServerMessagePlugin.beforeMessageRoute(Message message, org.apache.activemq.artemis.core.server.RoutingContext context, boolean direct, boolean rejectDuplicates)	Before a message is routed
default void	ActiveMQServerMessagePlugin.beforeSend(org.apache.activemq.artemis.core.server.ServerSession session, org.apache.activemq.artemis.core.transaction.Transaction tx, Message message, boolean direct, boolean noAutoCreateQueue)	Before a message is sent
default void	ActiveMQServerMessagePlugin.beforeSend(org.apache.activemq.artemis.core.transaction.Transaction tx, Message message, boolean direct, boolean noAutoCreateQueue)	Deprecated. use ActiveMQServerMessagePlugin.beforeSend(ServerSession, Transaction, Message, boolean, boolean)
default void	ActiveMQServerMessagePlugin.messageMoved(org.apache.activemq.artemis.core.transaction.Transaction tx, org.apache.activemq.artemis.core.server.MessageReference ref, org.apache.activemq.artemis.core.server.impl.AckReason reason, SimpleString destAddress, Long destQueueID, org.apache.activemq.artemis.core.server.ServerConsumer consumer, Message newMessage, org.apache.activemq.artemis.core.postoffice.RoutingStatus result)	A message has been moved
default void	ActiveMQServerMessagePlugin.onMessageRouteException(Message message, org.apache.activemq.artemis.core.server.RoutingContext context, boolean direct, boolean rejectDuplicates, Exception e)	When there was an error routing the message
default void	ActiveMQServerMessagePlugin.onSendException(org.apache.activemq.artemis.core.server.ServerSession session, org.apache.activemq.artemis.core.transaction.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.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, org.apache.activemq.artemis.core.persistence.CoreMessageObjectPools pools)
Message	MessagePersister.decode(ActiveMQBuffer buffer, Message record, org.apache.activemq.artemis.core.persistence.CoreMessageObjectPools pools, org.apache.activemq.artemis.core.persistence.StorageManager storageManager)
static Message	EmbedMessageUtil.extractEmbedded(ICoreMessage message, org.apache.activemq.artemis.core.persistence.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 org.apache.activemq.artemis.core.persistence.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, org.apache.activemq.artemis.core.persistence.CoreMessageObjectPools pools)
Message	MessagePersister.decode(ActiveMQBuffer buffer, Message record, org.apache.activemq.artemis.core.persistence.CoreMessageObjectPools pools, org.apache.activemq.artemis.core.persistence.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)

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(org.apache.activemq.artemis.core.persistence.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, int senderID, SendAcknowledgementHandler messageHandler)
abstract int	SessionContext.sendServerLargeMessageChunk(Message msgI, long messageBodySize, boolean sendBlocking, boolean lastChunk, byte[] chunk, int senderID, SendAcknowledgementHandler messageHandler)