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.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.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 and Description
interface	ICoreMessage This interface is only to determine the API of methods required for Core Messages

Classes in org.apache.activemq.artemis.api.core that implement Message

Modifier and Type	Class and Description
class	RefCountMessage

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

Modifier and Type	Method and 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
Message	Message.putBooleanProperty(SimpleString key, boolean value)
Message	Message.putBooleanProperty(String key, boolean value)
Message	Message.putByteProperty(SimpleString key, byte value)
Message	Message.putByteProperty(String key, byte value)
Message	Message.putBytesProperty(SimpleString key, byte[] value)
Message	Message.putBytesProperty(String key, byte[] value)
Message	Message.putCharProperty(SimpleString key, char value)
Message	Message.putCharProperty(String key, char value)
Message	Message.putDoubleProperty(SimpleString key, double value)
Message	Message.putDoubleProperty(String key, double value)
default Message	Message.putExtraBytesProperty(SimpleString key, byte[] value)
Message	Message.putFloatProperty(SimpleString key, float value)
Message	Message.putFloatProperty(String key, float value)
Message	Message.putIntProperty(SimpleString key, int value)
Message	Message.putIntProperty(String key, int value)
Message	Message.putLongProperty(SimpleString key, long value)
Message	Message.putLongProperty(String key, long value)
Message	Message.putObjectProperty(SimpleString key, Object value)
Message	Message.putObjectProperty(String key, Object value)
Message	Message.putShortProperty(SimpleString key, short value)
Message	Message.putShortProperty(String key, short value)
Message	Message.putStringProperty(SimpleString key, SimpleString value)
Message	Message.putStringProperty(SimpleString key, String value)
Message	Message.putStringProperty(String key, String value) Puts a String property in this message.
Message	Message.setAddress(SimpleString address) This will set the address on CoreMessage.
Message	Message.setAddress(String address) Look at setAddress(SimpleString) for the doc.
default Message	Message.setAnnotation(SimpleString key, Object value) Callers must call reencode() in order to be sent to clients
Message	Message.setBuffer(io.netty.buffer.ByteBuf buffer) The buffer will belong to this message, until release is called.
default Message	Message.setConnectionID(String connectionID)
Message	RefCountMessage.setContext(RefCountMessageListener context)
Message	Message.setContext(RefCountMessageListener context)
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.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 and Description
Persister<Message>	Message.getPersister()

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

Modifier and Type	Method and Description
void	ICoreMessage.copyHeadersAndProperties(Message msg) Used on large messages treatment
void	RefCountMessageListener.durableDown(Message message, int durableCount)
void	RefCountMessageListener.durableUp(Message message, int durableCount)
void	RefCountMessageListener.nonDurableDown(Message message, int nonDurableCoun)
void	RefCountMessageListener.nonDurableUp(Message message, int nonDurableCoun)
default void	Message.referenceOriginalMessage(Message original, String originalQueue)

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 and 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 and Description
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	ClientProducer.send(String address, Message message) 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.

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 and 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 and Description
Message	XMLMessageImporter.MessageInfo.message

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

Modifier and Type	Method and Description
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 and 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 and Description
ResetLimitWrappedActiveMQBuffer(int limit, ActiveMQBuffer buffer, Message message)
ResetLimitWrappedActiveMQBuffer(int limit, io.netty.buffer.ByteBuf 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 and Description
interface	ClientLargeMessageInternal
interface	ClientMessageInternal

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

Modifier and Type	Class and 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 and Description
Message	ClientMessageImpl.copy()

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

Modifier and Type	Method and Description
void	ClientSessionInternal.acknowledge(ClientConsumer consumer, Message message)
void	ClientSessionImpl.acknowledge(ClientConsumer consumer, Message message) Acknowledges all messages received by the consumer so far.
void	ClientSessionInternal.expire(ClientConsumer consumer, Message message)
void	ClientSessionImpl.expire(ClientConsumer consumer, Message message)
void	ClientSessionInternal.individualAcknowledge(ClientConsumer consumer, Message message)
void	ClientSessionImpl.individualAcknowledge(ClientConsumer consumer, Message message)
void	ClientSessionInternal.scheduleConfirmation(SendAcknowledgementHandler handler, Message message)
void	ClientSessionImpl.scheduleConfirmation(SendAcknowledgementHandler handler, 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	ClientProducerImpl.send(String address1, Message message)
void	ClientSessionInternal.setAddress(Message message, SimpleString address) This will set the address at the message
void	ClientSessionImpl.setAddress(Message message, SimpleString address)

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 and 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 and 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 and Description
interface	MessageInternal Deprecated.

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

Modifier and Type	Class and 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 and Description
Message	MessageInternalImpl.copy() Deprecated. It will generate a new instance of the message encode, being a deep copy, new properties, new everything
Message	CoreMessage.copy()
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	CoreMessage.copy(long newID)
Message	CoreMessagePersister.decode(ActiveMQBuffer buffer, Message record)
Message	MessageInternalImpl.putBooleanProperty(SimpleString key, boolean value) Deprecated.
Message	MessageInternalImpl.putBooleanProperty(String key, boolean value) Deprecated.
Message	MessageInternalImpl.putByteProperty(SimpleString key, byte value) Deprecated.
Message	MessageInternalImpl.putByteProperty(String key, byte value) Deprecated.
Message	MessageInternalImpl.putBytesProperty(SimpleString key, byte[] value) Deprecated.
Message	MessageInternalImpl.putBytesProperty(String key, byte[] value) Deprecated.
Message	MessageInternalImpl.putCharProperty(SimpleString key, char value) Deprecated.
Message	MessageInternalImpl.putCharProperty(String key, char value) Deprecated.
Message	MessageInternalImpl.putDoubleProperty(SimpleString key, double value) Deprecated.
Message	MessageInternalImpl.putDoubleProperty(String key, double value) Deprecated.
Message	MessageInternalImpl.putFloatProperty(SimpleString key, float value) Deprecated.
Message	MessageInternalImpl.putFloatProperty(String key, float value) Deprecated.
Message	MessageInternalImpl.putIntProperty(SimpleString key, int value) Deprecated.
Message	MessageInternalImpl.putIntProperty(String key, int value) Deprecated.
Message	MessageInternalImpl.putLongProperty(SimpleString key, long value) Deprecated.
Message	MessageInternalImpl.putLongProperty(String key, long value) Deprecated.
Message	MessageInternalImpl.putObjectProperty(SimpleString key, Object value) Deprecated.
Message	MessageInternalImpl.putObjectProperty(String key, Object value) Deprecated.
Message	MessageInternalImpl.putShortProperty(SimpleString key, short value) Deprecated.
Message	MessageInternalImpl.putShortProperty(String key, short value) Deprecated.
Message	MessageInternalImpl.putStringProperty(SimpleString key, SimpleString value) Deprecated.
Message	MessageInternalImpl.putStringProperty(SimpleString key, String value) Deprecated.
Message	MessageInternalImpl.putStringProperty(String key, String value) Deprecated. Puts a String property in this message.
Message	MessageInternalImpl.setAddress(SimpleString address) Deprecated.
Message	MessageInternalImpl.setAddress(String address) Deprecated.
Message	MessageInternalImpl.setBuffer(io.netty.buffer.ByteBuf buffer) Deprecated. The buffer will belong to this message, until release is called.
Message	MessageInternalImpl.setContext(RefCountMessageListener context) Deprecated.
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 and Description
Persister<Message>	MessageInternalImpl.getPersister() Deprecated.
Persister<Message>	CoreMessage.getPersister()

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

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

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 and Description
Message	PagedMessage.getMessage()

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

Modifier and Type	Method and Description
boolean	PagingStore.page(Message message, Transaction tx, RouteContextList listCtx, ReentrantReadWriteLock.ReadLock readLock) 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 and 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 and Description
Message	PagedMessageImpl.getMessage()

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

Modifier and Type	Method and Description
void	PagingStoreImpl.durableDown(Message message, int durableCount)
void	PagingStoreImpl.durableUp(Message message, int durableCount)
void	PagingStoreImpl.nonDurableDown(Message message, int count)
void	PagingStoreImpl.nonDurableUp(Message message, int count)
boolean	PagingStoreImpl.page(Message message, Transaction tx, RouteContextList listCtx, ReentrantReadWriteLock.ReadLock managerLock)

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

Constructor and 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 and 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 and Description
class	LargeServerMessageImpl

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

Modifier and Type	Method and Description
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)

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

Modifier and Type	Method and Description
boolean	AbstractJournalStorageManager.addToPage(PagingStore store, Message msg, Transaction tx, RouteContextList listCtx)
LargeServerMessage	JournalStorageManager.createLargeMessage(long id, Message message)
void	LargeServerMessageImpl.referenceOriginalMessage(Message original, String originalQueue)
void	AbstractJournalStorageManager.storeMessage(Message message)
void	AbstractJournalStorageManager.storeMessageTransactional(long txID, Message message)

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

Modifier and Type	Method and Description
protected LargeServerMessage	JournalStorageManager.parseLargeMessage(Map<Long,Message> messages, ActiveMQBuffer buff)
protected abstract LargeServerMessage	AbstractJournalStorageManager.parseLargeMessage(Map<Long,Message> messages, ActiveMQBuffer buff)

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

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

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

Constructor and Description
LargeMessageTXFailureCallback(AbstractJournalStorageManager journalStorageManager, Map<Long,Message> messages)

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 and 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 and 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 and 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.reroute(Message message, Queue queue, Transaction tx)
RoutingStatus	PostOffice.route(Message message, boolean direct)
void	Bindings.route(Message message, RoutingContext context)
void	Binding.route(Message message, RoutingContext context)
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 and 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 and Description
boolean	LocalQueueBinding.isHighAcceptPriority(Message message)
boolean	DivertBinding.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.reroute(Message message, Queue queue, Transaction tx)
RoutingStatus	PostOfficeImpl.route(Message message, boolean direct)
void	LocalQueueBinding.route(Message message, RoutingContext context)
void	DivertBinding.route(Message message, RoutingContext context)
void	BindingsImpl.route(Message message, RoutingContext context)
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	LocalQueueBinding.routeWithAck(Message message, RoutingContext context)
void	DivertBinding.routeWithAck(Message message, RoutingContext context)

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

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

Modifier and Type	Method and 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

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

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

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

Constructor and Description
SessionReceiveClientLargeMessage(Message message)
SessionReceiveLargeMessage(long consumerID, Message message, long largeMessageSize, int deliveryCount)
SessionReceiveLargeMessage(Message message)
SessionSendContinuationMessage(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 and 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 and 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 and Description
interface	LargeServerMessage
interface	ServerMessage Deprecated.

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

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

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

Modifier and Type	Method and Description
static MessageReference	MessageReference.Factory.createReference(Message encode, Queue queue)
RoutingStatus	ServerSession.doSend(Transaction tx, Message msg, SimpleString originalAddress, boolean direct, boolean noAutoCreateQueue)
void	ActiveMQServerLogger.duplicateMessageDetected(Message message)
SimpleString	RoutingContext.getAddress(Message message)
boolean	Queue.hasMatchingConsumer(Message message)
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)

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 and 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 and 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 and Description
protected Message	ClusterConnectionBridge.beforeForward(Message message, SimpleString forwardingAddress)
protected Message	BridgeImpl.beforeForward(Message message, SimpleString forwardingAddress)

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

Modifier and Type	Method and Description
protected Message	ClusterConnectionBridge.beforeForward(Message message, SimpleString forwardingAddress)
protected Message	BridgeImpl.beforeForward(Message message, SimpleString forwardingAddress)
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 and Description
Message	MessageReferenceImpl.getMessage()

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

Modifier and Type	Method and Description
RoutingStatus	ServerSessionImpl.doSend(Transaction tx, Message msg, SimpleString originalAddress, boolean direct, boolean noAutoCreateQueue)
SimpleString	RoutingContextImpl.getAddress(Message message)
void	PostOfficeJournalLoader.handlePreparedSendMessage(Message message, Transaction tx, long queueID)
void	JournalLoader.handlePreparedSendMessage(Message message, Transaction tx, long queueID)
boolean	QueueImpl.hasMatchingConsumer(Message message)
void	QueueImpl.route(Message message, RoutingContext context)
void	DivertImpl.route(Message message, RoutingContext context)
void	QueueImpl.routeWithAck(Message message, RoutingContext context)
void	DivertImpl.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)

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

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

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

Constructor and 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 and 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 and Description
ICoreMessage	ManagementServiceImpl.handleMessage(Message message)

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 and Description
default void	ActiveMQServerPlugin.afterMessageRoute(Message message, RoutingContext context, boolean direct, boolean rejectDuplicates, RoutingStatus result) After a message is routed
default void	ActiveMQServerPlugin.afterSend(ServerSession session, Transaction tx, Message message, boolean direct, boolean noAutoCreateQueue, RoutingStatus result) After a message is sent
default void	ActiveMQServerPlugin.afterSend(Transaction tx, Message message, boolean direct, boolean noAutoCreateQueue, RoutingStatus result) Deprecated. use ActiveMQServerPlugin.afterSend(ServerSession, Transaction, Message, boolean, boolean, RoutingStatus)
default void	ActiveMQServerPlugin.beforeMessageRoute(Message message, RoutingContext context, boolean direct, boolean rejectDuplicates) Before a message is routed
default void	ActiveMQServerPlugin.beforeSend(ServerSession session, Transaction tx, Message message, boolean direct, boolean noAutoCreateQueue) Before a message is sent
default void	ActiveMQServerPlugin.beforeSend(Transaction tx, Message message, boolean direct, boolean noAutoCreateQueue) Deprecated. use ActiveMQServerPlugin.beforeSend(ServerSession, Transaction, Message, boolean, boolean)

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 and Description
void	LoggingActiveMQServerPlugin.afterMessageRoute(Message message, RoutingContext context, boolean direct, boolean rejectDuplicates, RoutingStatus result) After a message is routed
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.afterSendDetails(String messageID, Message message, String sessionName, Transaction tx, ServerSession session, boolean direct, boolean noAutoCreateQueue)
void	LoggingActiveMQServerPluginLogger.beforeMessageRoute(Message message, RoutingContext context, boolean direct, boolean rejectDuplicates)
void	LoggingActiveMQServerPlugin.beforeMessageRoute(Message message, RoutingContext context, boolean direct, boolean rejectDuplicates) Before a message is routed
void	LoggingActiveMQServerPluginLogger.beforeSend(Message message, Transaction tx, ServerSession session, boolean direct, boolean noAutoCreateQueue)
void	LoggingActiveMQServerPlugin.beforeSend(ServerSession session, Transaction tx, Message message, boolean direct, boolean noAutoCreateQueue) Before a message is sent

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 and Description
class	ServerMessageImpl Deprecated.

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

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

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

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

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

Constructor and 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 and 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 and 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 and 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 and Description
static void	MessageUtil.clearProperties(Message message)
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 Set<String>	MessageUtil.getPropertyNames(Message message)
static boolean	MessageUtil.propertyExists(Message message, String name)
static void	MessageUtil.setJMSCorrelationID(Message message, String correlationID)
static void	MessageUtil.setJMSCorrelationIDAsBytes(Message message, byte[] correlationID)
static void	MessageUtil.setJMSReplyTo(Message message, SimpleString dest)
static void	MessageUtil.setJMSReplyTo(Message message, String dest)
static void	MessageUtil.setJMSType(Message message, String type)

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 and Description
interface	MessageConverter<ProtocolMessage extends Message>

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

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

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

Modifier and Type	Method and Description
Message	MessagePersister.decode(ActiveMQBuffer buffer, Message record)
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 and 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 and 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)