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]

    Java API: Creates a JmsConsumer of envelopes containing messages.

    Java 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. final def asInstanceOf[T0]: T0
    Definition Classes
    Any
  6. def browse(settings: JmsBrowseSettings): Source[Message, NotUsed]

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

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

    Java API: Creates an JmsConsumer for byte arrays

  8. def clone(): AnyRef
    Attributes
    protected[java.lang]
    Definition Classes
    AnyRef
    Annotations
    @native() @throws( ... )
  9. def create(settings: JmsConsumerSettings): Source[Message, KillSwitch]

    Java API: Creates an JmsConsumer for javax.jms.Message

  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]

    Java API: Creates an JmsConsumer for Maps with primitive data types

  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]

    Java 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]

    Java API: Creates an JmsConsumer for texts

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

    Java API: Creates a JmsConsumer of envelopes containing messages.

    Java 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