c

org.apache.pekko.stream.connectors.jms

JmsByteMessagePassThrough

sealed class JmsByteMessagePassThrough[+PassThrough] extends JmsEnvelope[PassThrough] with JmsEnvelopeWithProperties[PassThrough]

Produces byte arrays to JMS, supports pass-through data.

PassThrough

the type of data passed through the flexiFlow

Source
JmsMessages.scala
Linear Supertypes
JmsEnvelopeWithProperties[PassThrough], JmsEnvelope[PassThrough], AnyRef, Any
Known Subclasses
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. JmsByteMessagePassThrough
  2. JmsEnvelopeWithProperties
  3. JmsEnvelope
  4. AnyRef
  5. Any
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. Protected

Value Members

  1. val bytes: Array[Byte]
  2. val destination: Option[Destination]
  3. def getDestination: Optional[Destination]

    Java API.

    Java API.

    Definition Classes
    JmsEnvelope
  4. def getHeaders: Collection[JmsHeader]

    Java API.

    Java API.

    Definition Classes
    JmsEnvelope
  5. def getPassThrough: PassThrough

    Java API

    Java API

    Definition Classes
    JmsEnvelope
  6. def getProperties: Map[String, Any]

    Java API.

    Java API.

    Definition Classes
    JmsEnvelope
  7. val headers: Set[JmsHeader]
  8. val passThrough: PassThrough
  9. val properties: Map[String, Any]
  10. def to(destination: Destination): JmsByteMessagePassThrough[PassThrough]
  11. def toQueue(name: String): JmsByteMessagePassThrough[PassThrough]
  12. def toTopic(name: String): JmsByteMessagePassThrough[PassThrough]
  13. def withHeader(jmsHeader: JmsHeader): JmsByteMessagePassThrough[PassThrough]

    Add a Jms header e.g.

    Add a Jms header e.g. JMSType

  14. def withPassThrough[PassThrough2](passThrough: PassThrough2): JmsByteMessagePassThrough[PassThrough2]
  15. def withProperties(map: Map[String, AnyRef]): JmsByteMessagePassThrough[PassThrough]

    Java API.

  16. def withProperties(props: Map[String, Any]): JmsByteMessagePassThrough[PassThrough]
  17. def withProperty(name: String, value: Any): JmsByteMessagePassThrough[PassThrough]

    Add a property

    Add a property

    Definition Classes
    JmsByteMessagePassThroughJmsEnvelopeWithProperties
  18. def withoutDestination: JmsByteMessagePassThrough[PassThrough]