Module io.helidon.messaging.connectors.jms
Package io.helidon.messaging.connectors.jms

Class JmsBytesMessage

java.lang.Object
io.helidon.messaging.connectors.jms.JmsBytesMessage
All Implemented Interfaces:
JmsMessage<byte[]>, Message<byte[]>
public class JmsBytesMessage extends Object
A JMS Bytes message representation.

  • Method Details

    • getJmsMessage

      public jakarta.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 jakarta.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 jakarta.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 jakarta.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

    • ack

      public CompletionStage<Void> ack()
      Specified by:
      ack in interface Message<T>

    • getNack

      public Function<Throwable,CompletionStage<Void>> getNack()
      Specified by:
      getNack in interface Message<T>