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:
javax.jms.Message
,javax.jms.StreamMessage
public class ActiveMQStreamCompatibleMessage extends ActiveMQStreamMessage
-
-
Field Summary
-
Fields inherited from class org.apache.activemq.artemis.jms.client.ActiveMQStreamMessage
TYPE
-
Fields inherited from class org.apache.activemq.artemis.jms.client.ActiveMQMessage
message, OLD_QUEUE_QUALIFIED_PREFIX, OLD_TEMP_QUEUE_QUALIFED_PREFIX, OLD_TEMP_TOPIC_QUALIFED_PREFIX, OLD_TOPIC_QUALIFIED_PREFIX, propertiesReadOnly, readOnly, replyTo
-
-
Constructor Summary
Constructors Constructor Description ActiveMQStreamCompatibleMessage()
ActiveMQStreamCompatibleMessage(javax.jms.StreamMessage foreign, ClientSession session)
ActiveMQStreamCompatibleMessage(ClientMessage message, ClientSession session)
ActiveMQStreamCompatibleMessage(ClientSession session)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description protected org.apache.activemq.artemis.api.core.SimpleString
checkPrefix(org.apache.activemq.artemis.api.core.SimpleString address)
javax.jms.Destination
getJMSReplyTo()
void
setJMSReplyTo(javax.jms.Destination dest)
-
Methods inherited from class org.apache.activemq.artemis.jms.client.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 org.apache.activemq.artemis.jms.client.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 java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
-
Methods inherited from interface javax.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 Detail
-
ActiveMQStreamCompatibleMessage
public ActiveMQStreamCompatibleMessage(ClientSession session)
-
ActiveMQStreamCompatibleMessage
public ActiveMQStreamCompatibleMessage(ClientMessage message, ClientSession session)
-
ActiveMQStreamCompatibleMessage
public ActiveMQStreamCompatibleMessage(javax.jms.StreamMessage foreign, ClientSession session) throws javax.jms.JMSException
- Throws:
javax.jms.JMSException
-
ActiveMQStreamCompatibleMessage
public ActiveMQStreamCompatibleMessage()
-
-
Method Detail
-
checkPrefix
protected org.apache.activemq.artemis.api.core.SimpleString checkPrefix(org.apache.activemq.artemis.api.core.SimpleString address)
- Overrides:
checkPrefix
in classActiveMQMessage
-
setJMSReplyTo
public void setJMSReplyTo(javax.jms.Destination dest) throws javax.jms.JMSException
- Specified by:
setJMSReplyTo
in interfacejavax.jms.Message
- Overrides:
setJMSReplyTo
in classActiveMQMessage
- Throws:
javax.jms.JMSException
-
getJMSReplyTo
public javax.jms.Destination getJMSReplyTo() throws javax.jms.JMSException
- Specified by:
getJMSReplyTo
in interfacejavax.jms.Message
- Overrides:
getJMSReplyTo
in classActiveMQMessage
- Throws:
javax.jms.JMSException
-
-