public class ActiveMQStreamCompatibleMessage extends ActiveMQStreamMessage
TYPE
message, OLD_QUEUE_QUALIFIED_PREFIX, OLD_TEMP_QUEUE_QUALIFED_PREFIX, OLD_TEMP_TOPIC_QUALIFED_PREFIX, OLD_TOPIC_QUALIFIED_PREFIX, propertiesReadOnly, readOnly, replyTo
Constructor and Description |
---|
ActiveMQStreamCompatibleMessage() |
ActiveMQStreamCompatibleMessage(ClientMessage message,
ClientSession session) |
ActiveMQStreamCompatibleMessage(ClientSession session) |
ActiveMQStreamCompatibleMessage(javax.jms.StreamMessage foreign,
ClientSession session) |
Modifier and Type | Method and Description |
---|---|
protected SimpleString |
checkPrefix(SimpleString address) |
javax.jms.Destination |
getJMSReplyTo() |
void |
setJMSReplyTo(javax.jms.Destination dest) |
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
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
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
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
public ActiveMQStreamCompatibleMessage(ClientSession session)
public ActiveMQStreamCompatibleMessage(ClientMessage message, ClientSession session)
public ActiveMQStreamCompatibleMessage(javax.jms.StreamMessage foreign, ClientSession session) throws javax.jms.JMSException
javax.jms.JMSException
public ActiveMQStreamCompatibleMessage()
protected SimpleString checkPrefix(SimpleString address)
checkPrefix
in class ActiveMQMessage
public void setJMSReplyTo(javax.jms.Destination dest) throws javax.jms.JMSException
setJMSReplyTo
in interface javax.jms.Message
setJMSReplyTo
in class ActiveMQMessage
javax.jms.JMSException
public javax.jms.Destination getJMSReplyTo() throws javax.jms.JMSException
getJMSReplyTo
in interface javax.jms.Message
getJMSReplyTo
in class ActiveMQMessage
javax.jms.JMSException
Copyright © 2019 The Apache Software Foundation. All rights reserved.