Class ActiveMQCompatibleMessage

java.lang.Object

org.apache.activemq.artemis.jms.client.ActiveMQMessage

org.apache.activemq.artemis.jms.client.compatible1X.ActiveMQCompatibleMessage

All Implemented Interfaces:

jakarta.jms.Message

public class ActiveMQCompatibleMessage
extends ActiveMQMessage

Field Summary

Fields inherited from class ActiveMQMessage

message, OLD_QUEUE_QUALIFIED_PREFIX, OLD_TEMP_QUEUE_QUALIFED_PREFIX, OLD_TEMP_TOPIC_QUALIFED_PREFIX, OLD_TOPIC_QUALIFIED_PREFIX, propertiesReadOnly, readOnly, replyTo, TYPE

Fields inherited from interface jakarta.jms.Message

DEFAULT_DELIVERY_DELAY, DEFAULT_DELIVERY_MODE, DEFAULT_PRIORITY, DEFAULT_TIME_TO_LIVE

Constructor Summary

Constructors

Constructor	Description
ActiveMQCompatibleMessage()
ActiveMQCompatibleMessage(byte type, org.apache.activemq.artemis.api.core.client.ClientSession session)
ActiveMQCompatibleMessage(jakarta.jms.Message foreign, byte type, org.apache.activemq.artemis.api.core.client.ClientSession session)
ActiveMQCompatibleMessage(jakarta.jms.Message foreign, org.apache.activemq.artemis.api.core.client.ClientSession session)
ActiveMQCompatibleMessage(org.apache.activemq.artemis.api.core.client.ClientMessage message, org.apache.activemq.artemis.api.core.client.ClientSession session)
ActiveMQCompatibleMessage(org.apache.activemq.artemis.api.core.client.ClientSession session)

Method Summary

Modifier and Type	Method	Description
org.apache.activemq.artemis.api.core.SimpleString	checkPrefix(org.apache.activemq.artemis.api.core.SimpleString address)
protected static org.apache.activemq.artemis.api.core.SimpleString	checkPrefix1X(org.apache.activemq.artemis.api.core.SimpleString address)
static ActiveMQMessage	createMessage(org.apache.activemq.artemis.api.core.client.ClientMessage message, org.apache.activemq.artemis.api.core.client.ClientSession session, ConnectionFactoryOptions options)
jakarta.jms.Destination	getJMSReplyTo()
void	setJMSReplyTo(jakarta.jms.Destination dest)

Methods inherited from class ActiveMQMessage

acknowledge, checkBuffer, checkPrefixStr, checkRead, checkWrite, clearBody, clearProperties, coreCompositeTypeToJMSCompositeType, coreMaptoJMSMap, createMessage, doBeforeReceive, doBeforeSend, getBody, getBodyInternal, getBooleanProperty, getByteProperty, getCoreMessage, getDoubleProperty, getFloatProperty, getIntProperty, getJMSCorrelationID, getJMSCorrelationIDAsBytes, getJMSDeliveryMode, getJMSDeliveryTime, getJMSDestination, getJMSExpiration, getJMSMessageID, getJMSPriority, getJMSRedelivered, getJMSTimestamp, getJMSType, getLongProperty, getObjectProperty, getPropertyNames, getShortProperty, getStringProperty, getType, hasNoBody, isBodyAssignableTo, prefixOf, propertyExists, resetMessageID, saveToOutputStream, setBooleanProperty, setByteProperty, setClientAcknowledge, setDoubleProperty, setFloatProperty, setIndividualAcknowledge, setInputStream, setIntProperty, setJMSCorrelationID, setJMSCorrelationIDAsBytes, setJMSDeliveryMode, setJMSDeliveryTime, setJMSDestination, setJMSExpiration, setJMSMessageID, setJMSPriority, setJMSRedelivered, setJMSTimestamp, setJMSType, setLongProperty, setObjectProperty, setOutputStream, setShortProperty, setStringProperty, toString, waitCompletionOnStream

Methods inherited from class Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Constructor Details

ActiveMQCompatibleMessage

public ActiveMQCompatibleMessage(byte type,
 org.apache.activemq.artemis.api.core.client.ClientSession session)

ActiveMQCompatibleMessage

public ActiveMQCompatibleMessage(org.apache.activemq.artemis.api.core.client.ClientSession session)

ActiveMQCompatibleMessage

public ActiveMQCompatibleMessage(org.apache.activemq.artemis.api.core.client.ClientMessage message,
 org.apache.activemq.artemis.api.core.client.ClientSession session)

ActiveMQCompatibleMessage

public ActiveMQCompatibleMessage(jakarta.jms.Message foreign,
 org.apache.activemq.artemis.api.core.client.ClientSession session)
                          throws jakarta.jms.JMSException

Throws:

jakarta.jms.JMSException

ActiveMQCompatibleMessage

public ActiveMQCompatibleMessage()

ActiveMQCompatibleMessage

public ActiveMQCompatibleMessage(jakarta.jms.Message foreign,
 byte type,
 org.apache.activemq.artemis.api.core.client.ClientSession session)
                          throws jakarta.jms.JMSException

Throws:

jakarta.jms.JMSException

Method Details

getJMSReplyTo

public jakarta.jms.Destination getJMSReplyTo()
                                      throws jakarta.jms.JMSException

Specified by:

getJMSReplyTo in interface jakarta.jms.Message

Overrides:

getJMSReplyTo in class ActiveMQMessage

Throws:

jakarta.jms.JMSException

setJMSReplyTo

public void setJMSReplyTo(jakarta.jms.Destination dest)
                   throws jakarta.jms.JMSException

Specified by:

setJMSReplyTo in interface jakarta.jms.Message

Overrides:

setJMSReplyTo in class ActiveMQMessage

Throws:

jakarta.jms.JMSException

checkPrefix

public org.apache.activemq.artemis.api.core.SimpleString checkPrefix(org.apache.activemq.artemis.api.core.SimpleString address)

Overrides:

checkPrefix in class ActiveMQMessage

checkPrefix1X

protected static org.apache.activemq.artemis.api.core.SimpleString checkPrefix1X(org.apache.activemq.artemis.api.core.SimpleString address)

createMessage

public static ActiveMQMessage createMessage(org.apache.activemq.artemis.api.core.client.ClientMessage message,
 org.apache.activemq.artemis.api.core.client.ClientSession session,
 ConnectionFactoryOptions options)