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. final def !=(arg0: Any): Boolean
    Definition Classes
    AnyRef → Any
  2. final def ##: Int
    Definition Classes
    AnyRef → Any
  3. final def ==(arg0: Any): Boolean
    Definition Classes
    AnyRef → Any
  4. final def asInstanceOf[T0]: T0
    Definition Classes
    Any
  5. def byteStringSink(settings: JmsProducerSettings): Sink[ByteString, Future[Done]]

    Create a sink to send ByteStrings to a JMS broker.

  6. def bytesSink(settings: JmsProducerSettings): Sink[Array[Byte], Future[Done]]

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

  7. def clone(): AnyRef
    Attributes
    protected[lang]
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.CloneNotSupportedException]) @IntrinsicCandidate() @native()
  8. final def eq(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  9. def equals(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef → Any
  10. 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.

  11. def flow[T <: JmsMessage](settings: JmsProducerSettings): Flow[T, T, JmsProducerStatus]

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

  12. final def getClass(): Class[_ <: AnyRef]
    Definition Classes
    AnyRef → Any
    Annotations
    @IntrinsicCandidate() @native()
  13. def hashCode(): Int
    Definition Classes
    AnyRef → Any
    Annotations
    @IntrinsicCandidate() @native()
  14. final def isInstanceOf[T0]: Boolean
    Definition Classes
    Any
  15. def mapSink(settings: JmsProducerSettings): Sink[Map[String, Any], Future[Done]]

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

  16. final def ne(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  17. final def notify(): Unit
    Definition Classes
    AnyRef
    Annotations
    @IntrinsicCandidate() @native()
  18. final def notifyAll(): Unit
    Definition Classes
    AnyRef
    Annotations
    @IntrinsicCandidate() @native()
  19. def objectSink(settings: JmsProducerSettings): Sink[Serializable, Future[Done]]

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

  20. def sink(settings: JmsProducerSettings): Sink[JmsMessage, Future[Done]]

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

  21. final def synchronized[T0](arg0: => T0): T0
    Definition Classes
    AnyRef
  22. def textSink(settings: JmsProducerSettings): Sink[String, Future[Done]]

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

  23. def toString(): String
    Definition Classes
    AnyRef → Any
  24. final def wait(arg0: Long, arg1: Int): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.InterruptedException])
  25. final def wait(arg0: Long): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.InterruptedException]) @native()
  26. final def wait(): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.InterruptedException])

Deprecated Value Members

  1. def finalize(): Unit
    Attributes
    protected[lang]
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.Throwable]) @Deprecated
    Deprecated

    (Since version 9)

Inherited from AnyRef

Inherited from Any

Ungrouped