Class JmsBytesMessage

  • All Implemented Interfaces:
    JmsMessage<byte[]>, Message<byte[]>

    public class JmsBytesMessage
    extends Object
    A JMS Bytes message representation.
    • Method Detail

      • getJmsMessage

        public javax.jms.BytesMessage getJmsMessage()
        Description copied from interface: JmsMessage
        Original JMS message received.
        Returns:
        original JMS message received
      • asInputStream

        public InputStream asInputStream()
        Return InputStream which is able to read JMS ByteMessage.
        Returns:
        InputStream supplying bytes from received JMS ByteMessage.
      • getPayload

        public byte[] getPayload()
      • getProperty

        public <P> P getProperty​(String name)
        Description copied from interface: JmsMessage
        Get JMS property by name.
        Specified by:
        getProperty in interface JmsMessage<T>
        Type Parameters:
        P - expected type of the property, has to be Boolean, Byte, Short, Integer, Long, Float, Double or String
        Parameters:
        name - the name of the JMS property
        Returns:
        property value with the specified name or null
      • hasProperty

        public boolean hasProperty​(String name)
        Description copied from interface: JmsMessage
        Check if JMS property exists.
        Specified by:
        hasProperty in interface JmsMessage<T>
        Parameters:
        name - the name of the JMS property
        Returns:
        true if property exists
      • getPropertyNames

        public Set<String> getPropertyNames()
        Description copied from interface: JmsMessage
        Return set of all JMS property names.
        Specified by:
        getPropertyNames in interface JmsMessage<T>
        Returns:
        JMS property names
      • getJmsSession

        public javax.jms.Session getJmsSession()
        Description copied from interface: JmsMessage
        Metadata about the JMS session.
        Specified by:
        getJmsSession in interface JmsMessage<T>
        Returns:
        JMS session
      • getJmsConnection

        public javax.jms.Connection getJmsConnection()
        Description copied from interface: JmsMessage
        Get client's connection to its JMS provider.
        Specified by:
        getJmsConnection in interface JmsMessage<T>
        Returns:
        JMS connection
      • getJmsConnectionFactory

        public javax.jms.ConnectionFactory getJmsConnectionFactory()
        Description copied from interface: JmsMessage
        Get JMS connection factory.
        Specified by:
        getJmsConnectionFactory in interface JmsMessage<T>
        Returns:
        JMS connection factory
      • isAck

        public boolean isAck()
        Description copied from interface: JmsMessage
        Check if message has been acknowledged yet.
        Specified by:
        isAck in interface JmsMessage<T>
        Returns:
        true if message has been acknowledged