Packages

object JmsConsumer

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

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. def ackSource(settings: JmsConsumerSettings): Source[AckEnvelope, KillSwitch]

    Scala API: Creates a JmsConsumer of envelopes containing messages.

    Scala API: Creates a JmsConsumer of envelopes containing messages. It requires explicit acknowledgements on the envelopes. The acknowledgements must be called on the envelope and not on the message inside.

    settings

    The settings for the ack source.

    returns

    Source for JMS messages in an AckEnvelope.

  5. def apply(settings: JmsConsumerSettings): Source[Message, KillSwitch]

    Scala API: Creates an JmsConsumer for javax.jms.Message instances

  6. final def asInstanceOf[T0]: T0
    Definition Classes
    Any
  7. def browse(settings: JmsBrowseSettings): Source[Message, NotUsed]

    Scala API: Creates a JmsConsumer for browsing messages non-destructively

  8. def bytesSource(settings: JmsConsumerSettings): Source[Array[Byte], KillSwitch]

    Scala API: Creates an JmsConsumer for byte arrays

  9. def clone(): AnyRef
    Attributes
    protected[java.lang]
    Definition Classes
    AnyRef
    Annotations
    @native() @throws( ... )
  10. final def eq(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  11. def equals(arg0: Any): Boolean
    Definition Classes
    AnyRef → Any
  12. def finalize(): Unit
    Attributes
    protected[java.lang]
    Definition Classes
    AnyRef
    Annotations
    @throws( classOf[java.lang.Throwable] )
  13. final def getClass(): Class[_]
    Definition Classes
    AnyRef → Any
    Annotations
    @native()
  14. def hashCode(): Int
    Definition Classes
    AnyRef → Any
    Annotations
    @native()
  15. final def isInstanceOf[T0]: Boolean
    Definition Classes
    Any
  16. def mapSource(settings: JmsConsumerSettings): Source[Map[String, Any], KillSwitch]

    Scala API: Creates an JmsConsumer for Maps with primitive datatypes

  17. final def ne(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  18. final def notify(): Unit
    Definition Classes
    AnyRef
    Annotations
    @native()
  19. final def notifyAll(): Unit
    Definition Classes
    AnyRef
    Annotations
    @native()
  20. def objectSource(settings: JmsConsumerSettings): Source[Serializable, KillSwitch]

    Scala API: Creates an JmsConsumer for serializable objects

  21. final def synchronized[T0](arg0: ⇒ T0): T0
    Definition Classes
    AnyRef
  22. def textSource(settings: JmsConsumerSettings): Source[String, KillSwitch]

    Scala API: Creates an JmsConsumer for texts

  23. def toString(): String
    Definition Classes
    AnyRef → Any
  24. def txSource(settings: JmsConsumerSettings): Source[TxEnvelope, KillSwitch]

    Scala API: Creates a JmsConsumer of envelopes containing messages.

    Scala API: Creates a JmsConsumer of envelopes containing messages. It requires explicit commit or rollback on the envelope.

    settings

    The settings for the tx source

    returns

    Source of the JMS messages in a TxEnvelope

  25. final def wait(): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )
  26. final def wait(arg0: Long, arg1: Int): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )
  27. final def wait(arg0: Long): Unit
    Definition Classes
    AnyRef
    Annotations
    @native() @throws( ... )

Inherited from AnyRef

Inherited from Any

Ungrouped