object JmsConsumer
- Alphabetic
- By Inheritance
- JmsConsumer
- AnyRef
- Any
- Hide All
- Show All
- Public
- Protected
Value Members
- 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.
- 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.
- 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
- def bytesSource(settings: JmsConsumerSettings): Source[Array[Byte], JmsConsumerControl]
Creates a source emitting byte arrays, and materializes a control instance to shut down the consumer.
- def mapSource(settings: JmsConsumerSettings): Source[Map[String, Any], JmsConsumerControl]
Creates a source emitting maps, and materializes a control instance to shut down the consumer.
- def objectSource(settings: JmsConsumerSettings): Source[Serializable, JmsConsumerControl]
Creates a source emitting de-serialized objects, and materializes a control instance to shut down the consumer.
- def textSource(settings: JmsConsumerSettings): Source[String, JmsConsumerControl]
Creates a source emitting Strings, and materializes a control instance to shut down the consumer.
- 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.