Packages

object JmsProducer

Factory methods to create JMS producers.

Source
JmsProducer.scala
Linear Supertypes
AnyRef, Any
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. JmsProducer
  2. AnyRef
  3. Any
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. Protected

Value Members

  1. def byteStringSink(settings: JmsProducerSettings): Sink[ByteString, CompletionStage[Done]]

    Create a sink to send ByteStrings to a JMS broker.

  2. def bytesSink(settings: JmsProducerSettings): Sink[Array[Byte], CompletionStage[Done]]

    Create a sink to send byte arrays to a JMS broker.

  3. def flexiFlow[PassThrough](settings: JmsProducerSettings): Flow[JmsEnvelope[PassThrough], JmsEnvelope[PassThrough], JmsProducerStatus]

    Create a flow to send JmsEnvelope sub-classes to a JMS broker to support pass-through of data.

  4. def flow[R <: JmsMessage](settings: JmsProducerSettings): Flow[R, R, JmsProducerStatus]

    Create a flow to send JmsMessage sub-classes to a JMS broker.

  5. def mapSink(settings: JmsProducerSettings): Sink[Map[String, Any], CompletionStage[Done]]

    Create a sink to send map structures to a JMS broker.

  6. def objectSink(settings: JmsProducerSettings): Sink[Serializable, CompletionStage[Done]]

    Create a sink to send serialized objects to a JMS broker.

  7. def sink[R <: JmsMessage](settings: JmsProducerSettings): Sink[R, CompletionStage[Done]]

    Create a sink to send JmsMessage sub-classes to a JMS broker.

  8. def textSink(settings: JmsProducerSettings): Sink[String, CompletionStage[Done]]

    Create a sink to send Strings as text messages to a JMS broker.