Packages

object JmsConsumer

Factory methods to create JMS consumers.

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. Protected

Value Members

  1. def ackSource(settings: JmsConsumerSettings): Source[AckEnvelope, JmsConsumerControl]

    Creates a source emitting AckEnvelope instances, and materializes a control instance to shut down the consumer.

    Creates a source emitting AckEnvelope instances, and materializes a control instance to shut down the consumer. It requires explicit acknowledgements on the envelopes. The acknowledgements must be called on the envelope and not on the message inside.

  2. def apply(settings: JmsConsumerSettings): Source[Message, JmsConsumerControl]

    Creates a source emitting jakarta.jms.Message instances, and materializes a control instance to shut down the consumer.

  3. def browse(settings: JmsBrowseSettings): Source[Message, NotUsed]

    Creates a source browsing a JMS destination (which does not consume the messages) and emitting jakarta.jms.Message instances.

    Creates a source browsing a JMS destination (which does not consume the messages) and emitting jakarta.jms.Message instances. Completes: when all messages have been read

  4. def bytesSource(settings: JmsConsumerSettings): Source[Array[Byte], JmsConsumerControl]

    Creates a source emitting byte arrays, and materializes a control instance to shut down the consumer.

  5. def mapSource(settings: JmsConsumerSettings): Source[Map[String, Any], JmsConsumerControl]

    Creates a source emitting maps, and materializes a control instance to shut down the consumer.

  6. def objectSource(settings: JmsConsumerSettings): Source[Serializable, JmsConsumerControl]

    Creates a source emitting de-serialized objects, and materializes a control instance to shut down the consumer.

  7. def textSource(settings: JmsConsumerSettings): Source[String, JmsConsumerControl]

    Creates a source emitting Strings, and materializes a control instance to shut down the consumer.

  8. def txSource(settings: JmsConsumerSettings): Source[TxEnvelope, JmsConsumerControl]

    Creates a source emitting TxEnvelope instances, and materializes a control instance to shut down the consumer.

    Creates a source emitting TxEnvelope instances, and materializes a control instance to shut down the consumer. It requires explicit committing or rollback on the envelopes.