Uses of Interface
org.apache.activemq.artemis.api.core.Message
-
-
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 MessagesMethods 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 everythingMessage
Message. copy(long newID)
It will generate a new instance of the message encode, being a deep copy, new properties, new everythingdefault Message
Message. copy(long newID, boolean isExpiryOrDLQ)
It will generate a new instance of the message encode, being a deep copy, new properties, new everythingMessage
Message. putBooleanProperty(String key, boolean value)
Callers must callreencode()
in order to be sent to clientsMessage
Message. putBooleanProperty(SimpleString key, boolean value)
Callers must callreencode()
in order to be sent to clientsMessage
Message. putByteProperty(String key, byte value)
Callers must callreencode()
in order to be sent to clientsMessage
Message. putByteProperty(SimpleString key, byte value)
Callers must callreencode()
in order to be sent to clientsMessage
Message. putBytesProperty(String key, byte[] value)
Callers must callreencode()
in order to be sent to clientsMessage
Message. putBytesProperty(SimpleString key, byte[] value)
Callers must callreencode()
in order to be sent to clientsMessage
Message. putCharProperty(String key, char value)
Callers must callreencode()
in order to be sent to clientsMessage
Message. putCharProperty(SimpleString key, char value)
Callers must callreencode()
in order to be sent to clientsMessage
Message. putDoubleProperty(String key, double value)
Callers must callreencode()
in order to be sent to clientsMessage
Message. putDoubleProperty(SimpleString key, double value)
Callers must callreencode()
in order to be sent to clientsdefault Message
Message. putExtraBytesProperty(SimpleString key, byte[] value)
Message
Message. putFloatProperty(String key, float value)
Callers must callreencode()
in order to be sent to clientsMessage
Message. putFloatProperty(SimpleString key, float value)
Callers must callreencode()
in order to be sent to clientsMessage
Message. putIntProperty(String key, int value)
Callers must callreencode()
in order to be sent to clientsMessage
Message. putIntProperty(SimpleString key, int value)
Callers must callreencode()
in order to be sent to clientsMessage
Message. putLongProperty(String key, long value)
Callers must callreencode()
in order to be sent to clientsMessage
Message. putLongProperty(SimpleString key, long value)
Callers must callreencode()
in order to be sent to clientsMessage
Message. putObjectProperty(String key, Object value)
Callers must callreencode()
in order to be sent to clientsMessage
Message. putObjectProperty(SimpleString key, Object value)
Callers must callreencode()
in order to be sent to clientsMessage
Message. putShortProperty(String key, short value)
Callers must callreencode()
in order to be sent to clientsMessage
Message. putShortProperty(SimpleString key, short value)
Callers must callreencode()
in order to be sent to clientsMessage
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 atsetAddress(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 callreencode()
in order to be sent to clientsdefault 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 ClientMessageMessage
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.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.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 messagedefault 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 routeddefault 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 sentdefault 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)
default void
ActiveMQServerFederationPlugin. beforeFederatedQueueConsumerMessageHandled(org.apache.activemq.artemis.core.server.federation.FederatedQueueConsumer consumer, Message message)
Before a federated queue consumer handles a messagedefault void
ActiveMQServerMessagePlugin. beforeMessageRoute(Message message, org.apache.activemq.artemis.core.server.RoutingContext context, boolean direct, boolean rejectDuplicates)
Before a message is routeddefault 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 sentdefault void
ActiveMQServerMessagePlugin. beforeSend(org.apache.activemq.artemis.core.transaction.Transaction tx, Message message, boolean direct, boolean noAutoCreateQueue)
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 messagedefault 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-idint
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 packetabstract 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)
-