Uses of Interface
org.apache.activemq.artemis.api.core.Message
Packages that use Message
Package
Description
-
Uses of Message in org.apache.activemq.artemis.api.core
Subinterfaces of Message in org.apache.activemq.artemis.api.coreModifier and TypeInterfaceDescriptioninterfaceThis interface is only to determine the API of methods required for Core MessagesMethods in org.apache.activemq.artemis.api.core that return MessageModifier and TypeMethodDescriptionMessage.copy()It will generate a new instance of the message encode, being a deep copy, new properties, new everythingMessage.copy(long newID) It will generate a new instance of the message encode, being a deep copy, new properties, new everythingdefault MessageMessage.copy(long newID, boolean isExpiryOrDLQ) It will generate a new instance of the message encode, being a deep copy, new properties, new everythingMessage.putBooleanProperty(String key, boolean value) Callers must callreencode()in order to be sent to clientsMessage.putBooleanProperty(SimpleString key, boolean value) Callers must callreencode()in order to be sent to clientsMessage.putByteProperty(String key, byte value) Callers must callreencode()in order to be sent to clientsMessage.putByteProperty(SimpleString key, byte value) Callers must callreencode()in order to be sent to clientsMessage.putBytesProperty(String key, byte[] value) Callers must callreencode()in order to be sent to clientsMessage.putBytesProperty(SimpleString key, byte[] value) Callers must callreencode()in order to be sent to clientsMessage.putCharProperty(String key, char value) Callers must callreencode()in order to be sent to clientsMessage.putCharProperty(SimpleString key, char value) Callers must callreencode()in order to be sent to clientsMessage.putDoubleProperty(String key, double value) Callers must callreencode()in order to be sent to clientsMessage.putDoubleProperty(SimpleString key, double value) Callers must callreencode()in order to be sent to clientsdefault MessageMessage.putExtraBytesProperty(SimpleString key, byte[] value) Message.putFloatProperty(String key, float value) Callers must callreencode()in order to be sent to clientsMessage.putFloatProperty(SimpleString key, float value) Callers must callreencode()in order to be sent to clientsMessage.putIntProperty(String key, int value) Callers must callreencode()in order to be sent to clientsMessage.putIntProperty(SimpleString key, int value) Callers must callreencode()in order to be sent to clientsMessage.putLongProperty(String key, long value) Callers must callreencode()in order to be sent to clientsMessage.putLongProperty(SimpleString key, long value) Callers must callreencode()in order to be sent to clientsMessage.putObjectProperty(String key, Object value) Callers must callreencode()in order to be sent to clientsMessage.putObjectProperty(SimpleString key, Object value) Callers must callreencode()in order to be sent to clientsMessage.putShortProperty(String key, short value) Callers must callreencode()in order to be sent to clientsMessage.putShortProperty(SimpleString key, short value) Callers must callreencode()in order to be sent to clientsMessage.putStringProperty(String key, String value) Puts a String property in this message.Message.putStringProperty(SimpleString key, String value) Message.putStringProperty(SimpleString key, SimpleString value) Message.setAddress(String address) Look atsetAddress(SimpleString)for the doc.Message.setAddress(SimpleString address) This will set the address on CoreMessage.default MessageMessage.setAnnotation(SimpleString key, Object value) Callers must callreencode()in order to be sent to clientsdefault MessageMessage.setBrokerProperty(SimpleString key, Object value) To be called by the broker on ocasions such as DLQ and expiry.ICoreMessage.setBuffer(io.netty.buffer.ByteBuf buffer) The buffer will belong to this message, until release is called.default MessageMessage.setConnectionID(String connectionID) default MessageMessage.setCorrelationID(Object correlationID) Message.setDurable(boolean durable) Sets whether this message is durable or not.Message.setExpiration(long expiration) Sets the expiration of this message.default MessageMessage.setGroupID(String groupID) default MessageMessage.setGroupID(SimpleString groupID) default MessageMessage.setGroupSequence(int sequence) default MessageMessage.setIngressTimestamp()default MessageMessage.setLastValueProperty(SimpleString lastValueName) Message.setMessageID(long id) Message.setPriority(byte priority) Sets the message priority.Message.setReplyTo(SimpleString address) default MessageMessage.setRoutingType(RoutingType routingType) default MessageMessage.setScheduledDeliveryTime(Long time) Message.setTimestamp(long timestamp) default MessageMessage.setType(byte type) Deprecated.do not use this, use through ICoreMessage or ClientMessagedefault MessageMessage.setValidatedUserID(String validatedUserID) Methods in org.apache.activemq.artemis.api.core that return types with arguments of type MessageModifier and TypeMethodDescriptionorg.apache.activemq.artemis.core.persistence.Persister<Message>Message.getPersister()Methods in org.apache.activemq.artemis.api.core with parameters of type MessageModifier and TypeMethodDescriptionstatic voidRefCountMessage.deferredDebug(Message message, String debugMessage, Object... args) voidRefCountMessageListener.durableDown(Message message, int durableCount) voidvoidICoreMessage.moveHeadersAndProperties(Message msg) Used on large messages treatment.voiddefault voidMessage.referenceOriginalMessage(Message original, SimpleString originalQueue) voiddefault voiddefault void -
Uses of Message in org.apache.activemq.artemis.api.core.client
Subinterfaces of Message in org.apache.activemq.artemis.api.core.clientModifier and TypeInterfaceDescriptioninterfaceA ClientMessage represents a message sent and/or received by ActiveMQ Artemis.Methods in org.apache.activemq.artemis.api.core.client with parameters of type MessageModifier and TypeMethodDescriptionvoidSends a message to the specified address instead of the ClientProducer's address.voidSends a message to an address.voidClientProducer.send(Message message, SendAcknowledgementHandler handler) Sends a message to the specified address instead of the ClientProducer's address.voidClientProducer.send(SimpleString address, Message message) Sends a message to the specified address instead of the ClientProducer's address.voidClientProducer.send(SimpleString address, Message message, SendAcknowledgementHandler handler) Sends a message to the specified address instead of the ClientProducer's address.voidSendAcknowledgementHandler.sendAcknowledged(Message message) Notifies the client that a message sent asynchronously has been received by the server.default voidSendAcknowledgementHandler.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 MessageModifier and TypeMethodDescriptionstatic booleanManagementHelper.hasOperationSucceeded(Message message) Returns whether the invocation of the management operation on the server resource succeeded.static booleanManagementHelper.isAttributesResult(Message message) Returns whether the JMS message corresponds to the result of a management attribute value.static booleanManagementHelper.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.spi.core.remoting
Methods in org.apache.activemq.artemis.spi.core.remoting with parameters of type MessageModifier and TypeMethodDescriptionabstract voidSessionContext.expireMessage(ClientConsumer consumer, Message message) abstract intSessionContext.getCreditsOnSendingFull(Message msgI) abstract voidSessionContext.sendACK(boolean individual, boolean block, ClientConsumer consumer, Message message) abstract intSessionContext.sendInitialChunkOnLargeMessage(Message msgI) it should return the number of credits (or bytes) used to send this packetabstract intSessionContext.sendLargeMessageChunk(Message msgI, long messageBodySize, boolean sendBlocking, boolean lastChunk, byte[] chunk, int reconnectID, int senderID, SendAcknowledgementHandler messageHandler) abstract intSessionContext.sendServerLargeMessageChunk(Message msgI, long messageBodySize, boolean sendBlocking, boolean lastChunk, byte[] chunk, int senderID, SendAcknowledgementHandler messageHandler)