Class ActiveMQStreamMessage

  • All Implemented Interfaces:
    javax.jms.Message, javax.jms.StreamMessage
    Direct Known Subclasses:
    ActiveMQStreamCompatibleMessage

    public class ActiveMQStreamMessage
    extends ActiveMQMessage
    implements javax.jms.StreamMessage
    ActiveMQ Artemis implementation of a JMS StreamMessage.
    • Constructor Detail

      • ActiveMQStreamMessage

        protected ActiveMQStreamMessage​(ClientSession session)
      • ActiveMQStreamMessage

        public ActiveMQStreamMessage​(javax.jms.StreamMessage foreign,
                                     ClientSession session)
                              throws javax.jms.JMSException
        Throws:
        javax.jms.JMSException
      • ActiveMQStreamMessage

        public ActiveMQStreamMessage()
    • Method Detail

      • readBoolean

        public boolean readBoolean()
                            throws javax.jms.JMSException
        Specified by:
        readBoolean in interface javax.jms.StreamMessage
        Throws:
        javax.jms.JMSException
      • readByte

        public byte readByte()
                      throws javax.jms.JMSException
        Specified by:
        readByte in interface javax.jms.StreamMessage
        Throws:
        javax.jms.JMSException
      • readShort

        public short readShort()
                        throws javax.jms.JMSException
        Specified by:
        readShort in interface javax.jms.StreamMessage
        Throws:
        javax.jms.JMSException
      • readChar

        public char readChar()
                      throws javax.jms.JMSException
        Specified by:
        readChar in interface javax.jms.StreamMessage
        Throws:
        javax.jms.JMSException
      • readInt

        public int readInt()
                    throws javax.jms.JMSException
        Specified by:
        readInt in interface javax.jms.StreamMessage
        Throws:
        javax.jms.JMSException
      • readLong

        public long readLong()
                      throws javax.jms.JMSException
        Specified by:
        readLong in interface javax.jms.StreamMessage
        Throws:
        javax.jms.JMSException
      • readFloat

        public float readFloat()
                        throws javax.jms.JMSException
        Specified by:
        readFloat in interface javax.jms.StreamMessage
        Throws:
        javax.jms.JMSException
      • readDouble

        public double readDouble()
                          throws javax.jms.JMSException
        Specified by:
        readDouble in interface javax.jms.StreamMessage
        Throws:
        javax.jms.JMSException
      • readString

        public java.lang.String readString()
                                    throws javax.jms.JMSException
        Specified by:
        readString in interface javax.jms.StreamMessage
        Throws:
        javax.jms.JMSException
      • readBytes

        public int readBytes​(byte[] value)
                      throws javax.jms.JMSException
        Specified by:
        readBytes in interface javax.jms.StreamMessage
        Throws:
        javax.jms.JMSException
      • readObject

        public java.lang.Object readObject()
                                    throws javax.jms.JMSException
        Specified by:
        readObject in interface javax.jms.StreamMessage
        Throws:
        javax.jms.JMSException
      • writeBoolean

        public void writeBoolean​(boolean value)
                          throws javax.jms.JMSException
        Specified by:
        writeBoolean in interface javax.jms.StreamMessage
        Throws:
        javax.jms.JMSException
      • writeByte

        public void writeByte​(byte value)
                       throws javax.jms.JMSException
        Specified by:
        writeByte in interface javax.jms.StreamMessage
        Throws:
        javax.jms.JMSException
      • writeShort

        public void writeShort​(short value)
                        throws javax.jms.JMSException
        Specified by:
        writeShort in interface javax.jms.StreamMessage
        Throws:
        javax.jms.JMSException
      • writeChar

        public void writeChar​(char value)
                       throws javax.jms.JMSException
        Specified by:
        writeChar in interface javax.jms.StreamMessage
        Throws:
        javax.jms.JMSException
      • writeInt

        public void writeInt​(int value)
                      throws javax.jms.JMSException
        Specified by:
        writeInt in interface javax.jms.StreamMessage
        Throws:
        javax.jms.JMSException
      • writeLong

        public void writeLong​(long value)
                       throws javax.jms.JMSException
        Specified by:
        writeLong in interface javax.jms.StreamMessage
        Throws:
        javax.jms.JMSException
      • writeFloat

        public void writeFloat​(float value)
                        throws javax.jms.JMSException
        Specified by:
        writeFloat in interface javax.jms.StreamMessage
        Throws:
        javax.jms.JMSException
      • writeDouble

        public void writeDouble​(double value)
                         throws javax.jms.JMSException
        Specified by:
        writeDouble in interface javax.jms.StreamMessage
        Throws:
        javax.jms.JMSException
      • writeString

        public void writeString​(java.lang.String value)
                         throws javax.jms.JMSException
        Specified by:
        writeString in interface javax.jms.StreamMessage
        Throws:
        javax.jms.JMSException
      • writeBytes

        public void writeBytes​(byte[] value)
                        throws javax.jms.JMSException
        Specified by:
        writeBytes in interface javax.jms.StreamMessage
        Throws:
        javax.jms.JMSException
      • writeBytes

        public void writeBytes​(byte[] value,
                               int offset,
                               int length)
                        throws javax.jms.JMSException
        Specified by:
        writeBytes in interface javax.jms.StreamMessage
        Throws:
        javax.jms.JMSException
      • writeObject

        public void writeObject​(java.lang.Object value)
                         throws javax.jms.JMSException
        Specified by:
        writeObject in interface javax.jms.StreamMessage
        Throws:
        javax.jms.JMSException
      • reset

        public void reset()
                   throws javax.jms.JMSException
        Specified by:
        reset in interface javax.jms.StreamMessage
        Throws:
        javax.jms.JMSException
      • clearBody

        public void clearBody()
                       throws javax.jms.JMSException
        Specified by:
        clearBody in interface javax.jms.Message
        Overrides:
        clearBody in class ActiveMQMessage
        Throws:
        javax.jms.JMSException
      • doBeforeSend

        public void doBeforeSend()
                          throws java.lang.Exception
        Overrides:
        doBeforeSend in class ActiveMQMessage
        Throws:
        java.lang.Exception
      • isBodyAssignableTo

        public boolean isBodyAssignableTo​(java.lang.Class c)
        Specified by:
        isBodyAssignableTo in interface javax.jms.Message
        Overrides:
        isBodyAssignableTo in class ActiveMQMessage