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
DEFAULT_DELIVERY_DELAY, DEFAULT_DELIVERY_MODE, DEFAULT_PRIORITY, DEFAULT_TIME_TO_LIVE
Constructor and Description |
---|
ActiveMQStreamCompatibleMessage() |
ActiveMQStreamCompatibleMessage(ClientMessage message,
ClientSession session) |
ActiveMQStreamCompatibleMessage(ClientSession session) |
ActiveMQStreamCompatibleMessage(StreamMessage foreign,
ClientSession session) |
Modifier and Type | Method and Description |
---|---|
protected SimpleString |
checkPrefix(SimpleString address) |
Destination |
getJMSReplyTo()
Gets the
Destination object to which a reply to this
message should be sent. |
void |
setJMSReplyTo(Destination dest)
Sets the
Destination object to which a reply to this
message should be sent. |
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(StreamMessage foreign, ClientSession session) throws JMSException
JMSException
public ActiveMQStreamCompatibleMessage()
protected SimpleString checkPrefix(SimpleString address)
checkPrefix
in class ActiveMQMessage
public void setJMSReplyTo(Destination dest) throws JMSException
Message
Destination
object to which a reply to this
message should be sent.
The JMSReplyTo
header field contains the destination
where a reply
to the current message should be sent. If it is null, no reply is
expected. The destination may be either a Queue
object or
a Topic
object.
Messages sent with a null JMSReplyTo
value may be a
notification of some event, or they may just be some data the sender
thinks is of interest.
Messages with a JMSReplyTo
value typically expect a
response. A response is optional; it is up to the client to decide.
These messages are called requests. A message sent in response to a
request is called a reply.
In some cases a client may wish to match a request it sent earlier
with a reply it has just received. The client can use the
JMSCorrelationID
header field for this purpose.
setJMSReplyTo
in interface Message
setJMSReplyTo
in class ActiveMQMessage
dest
- Destination
to which to send a response to
this messageJMSException
- if the JMS provider fails to set the
JMSReplyTo
destination due to some
internal error.Message.getJMSReplyTo()
public Destination getJMSReplyTo() throws JMSException
Message
Destination
object to which a reply to this
message should be sent.getJMSReplyTo
in interface Message
getJMSReplyTo
in class ActiveMQMessage
Destination
to which to send a response to this
messageJMSException
- if the JMS provider fails to get the
JMSReplyTo
destination due to some
internal error.Message.setJMSReplyTo(Destination)
Copyright © 2019 JBoss by Red Hat. All rights reserved.