Class ActiveMQStreamCompatibleMessage

java.lang.Object

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

org.apache.activemq.artemis.jms.client.ActiveMQStreamMessage

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

All Implemented Interfaces:

jakarta.jms.Message, jakarta.jms.StreamMessage

public class ActiveMQStreamCompatibleMessage
extends ActiveMQStreamMessage

Field Summary

Fields inherited from class ActiveMQStreamMessage

TYPE

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

Fields inherited from interface jakarta.jms.Message

DEFAULT_DELIVERY_DELAY, DEFAULT_DELIVERY_MODE, DEFAULT_PRIORITY, DEFAULT_TIME_TO_LIVE

Constructor Summary

Constructors

Constructor	Description
ActiveMQStreamCompatibleMessage()
ActiveMQStreamCompatibleMessage(jakarta.jms.StreamMessage foreign, org.apache.activemq.artemis.api.core.client.ClientSession session)
ActiveMQStreamCompatibleMessage(org.apache.activemq.artemis.api.core.client.ClientMessage message, org.apache.activemq.artemis.api.core.client.ClientSession session)
ActiveMQStreamCompatibleMessage(org.apache.activemq.artemis.api.core.client.ClientSession session)

Method Summary

Modifier and Type	Method	Description
protected org.apache.activemq.artemis.api.core.SimpleString	checkPrefix(org.apache.activemq.artemis.api.core.SimpleString address)
jakarta.jms.Destination	getJMSReplyTo()
void	setJMSReplyTo(jakarta.jms.Destination dest)

Methods inherited from class ActiveMQStreamMessage

clearBody, doBeforeSend, getType, isBodyAssignableTo, readBoolean, readByte, readBytes, readChar, readDouble, readFloat, readInt, readLong, readObject, readShort, readString, reset, writeBoolean, writeByte, writeBytes, writeBytes, writeChar, writeDouble, writeFloat, writeInt, writeLong, writeObject, writeShort, writeString

Methods inherited from class ActiveMQMessage

acknowledge, checkBuffer, checkPrefixStr, checkRead, checkWrite, clearProperties, coreCompositeTypeToJMSCompositeType, coreMaptoJMSMap, createMessage, createMessage, doBeforeReceive, getBody, getBodyInternal, getBooleanProperty, getByteProperty, getCoreMessage, getDoubleProperty, getFloatProperty, getIntProperty, getJMSCorrelationID, getJMSCorrelationIDAsBytes, getJMSDeliveryMode, getJMSDeliveryTime, getJMSDestination, getJMSExpiration, getJMSMessageID, getJMSPriority, getJMSRedelivered, getJMSTimestamp, getJMSType, getLongProperty, getObjectProperty, getPropertyNames, getShortProperty, getStringProperty, hasNoBody, 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

Methods inherited from interface jakarta.jms.Message

acknowledge, clearProperties, getBody, getBooleanProperty, getByteProperty, getDoubleProperty, getFloatProperty, getIntProperty, getJMSCorrelationID, getJMSCorrelationIDAsBytes, getJMSDeliveryMode, getJMSDeliveryTime, getJMSDestination, getJMSExpiration, getJMSMessageID, getJMSPriority, getJMSRedelivered, getJMSTimestamp, getJMSType, getLongProperty, getObjectProperty, getPropertyNames, getShortProperty, getStringProperty, propertyExists, setBooleanProperty, setByteProperty, setDoubleProperty, setFloatProperty, setIntProperty, setJMSCorrelationID, setJMSCorrelationIDAsBytes, setJMSDeliveryMode, setJMSDeliveryTime, setJMSDestination, setJMSExpiration, setJMSMessageID, setJMSPriority, setJMSRedelivered, setJMSTimestamp, setJMSType, setLongProperty, setObjectProperty, setShortProperty, setStringProperty

Constructor Details

ActiveMQStreamCompatibleMessage

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

ActiveMQStreamCompatibleMessage

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

ActiveMQStreamCompatibleMessage

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

Throws:

jakarta.jms.JMSException

ActiveMQStreamCompatibleMessage

public ActiveMQStreamCompatibleMessage()

Method Details

checkPrefix

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

Overrides:

checkPrefix in class ActiveMQMessage

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

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