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

Class ActiveMQBytesCompatibleMessage

java.lang.Object

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

org.apache.activemq.artemis.jms.client.ActiveMQBytesMessage

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

All Implemented Interfaces:

BytesMessage, Message

public class ActiveMQBytesCompatibleMessage
extends ActiveMQBytesMessage

Field Summary

Fields inherited from class org.apache.activemq.artemis.jms.client.ActiveMQBytesMessage

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

Fields inherited from interface jakarta.jms.Message

DEFAULT_DELIVERY_DELAY, DEFAULT_DELIVERY_MODE, DEFAULT_PRIORITY, DEFAULT_TIME_TO_LIVE

Constructor Summary

Constructors

Modifier	Constructor	Description
	ActiveMQBytesCompatibleMessage(BytesMessage foreign, ClientSession session)
protected	ActiveMQBytesCompatibleMessage(ClientMessage message, ClientSession session)
	ActiveMQBytesCompatibleMessage(ClientSession session)

Method Summary

Modifier and Type	Method	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.

Methods inherited from class org.apache.activemq.artemis.jms.client.ActiveMQBytesMessage

clearBody, doBeforeReceive, doBeforeSend, getBodyInternal, getBodyLength, getType, isBodyAssignableTo, readBoolean, readByte, readBytes, readBytes, readChar, readDouble, readFloat, readInt, readLong, readShort, readUnsignedByte, readUnsignedShort, readUTF, reset, writeBoolean, writeByte, writeBytes, writeBytes, writeChar, writeDouble, writeFloat, writeInt, writeLong, writeObject, writeShort, writeUTF

Methods inherited from class org.apache.activemq.artemis.jms.client.ActiveMQMessage

acknowledge, checkBuffer, checkPrefixStr, checkRead, checkWrite, clearProperties, coreCompositeTypeToJMSCompositeType, coreMaptoJMSMap, createMessage, createMessage, getBody, 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 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 Detail

ActiveMQBytesCompatibleMessage

public ActiveMQBytesCompatibleMessage(ClientSession session)

ActiveMQBytesCompatibleMessage

protected ActiveMQBytesCompatibleMessage(ClientMessage message,
                                         ClientSession session)

ActiveMQBytesCompatibleMessage

public ActiveMQBytesCompatibleMessage(BytesMessage foreign,
                                      ClientSession session)
                               throws JMSException

Throws:

JMSException

Method Detail

checkPrefix

protected SimpleString checkPrefix(SimpleString address)

Overrides:

checkPrefix in class ActiveMQMessage

setJMSReplyTo

public void setJMSReplyTo(Destination dest)
                   throws JMSException

Description copied from interface: Message

Sets the 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.

Specified by:

setJMSReplyTo in interface Message

Overrides:

setJMSReplyTo in class ActiveMQMessage

Parameters:

dest - Destination to which to send a response to this message

Throws:

JMSException - if the Jakarta Messaging provider fails to set the JMSReplyTo destination due to some internal error.

See Also:

Message.getJMSReplyTo()

getJMSReplyTo

public Destination getJMSReplyTo()
                          throws JMSException

Description copied from interface: Message

Gets the Destination object to which a reply to this message should be sent.

Specified by:

getJMSReplyTo in interface Message

Overrides:

getJMSReplyTo in class ActiveMQMessage

Returns:

Destination to which to send a response to this message

Throws:

JMSException - if the Jakarta Messaging provider fails to get the JMSReplyTo destination due to some internal error.

See Also:

Message.setJMSReplyTo(Destination)