Class ActiveMQStreamCompatibleMessage

  • All Implemented Interfaces:
    javax.jms.Message, javax.jms.StreamMessage

    public class ActiveMQStreamCompatibleMessage
    extends ActiveMQStreamMessage
    • Constructor Detail

      • ActiveMQStreamCompatibleMessage

        public ActiveMQStreamCompatibleMessage​(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 class ActiveMQMessage
      • setJMSReplyTo

        public void setJMSReplyTo​(javax.jms.Destination dest)
                           throws javax.jms.JMSException
        Specified by:
        setJMSReplyTo in interface javax.jms.Message
        Overrides:
        setJMSReplyTo in class ActiveMQMessage
        Throws:
        javax.jms.JMSException
      • getJMSReplyTo

        public javax.jms.Destination getJMSReplyTo()
                                            throws javax.jms.JMSException
        Specified by:
        getJMSReplyTo in interface javax.jms.Message
        Overrides:
        getJMSReplyTo in class ActiveMQMessage
        Throws:
        javax.jms.JMSException