object JmsConsumer
- Alphabetic
- By Inheritance
- JmsConsumer
- AnyRef
- Any
- Hide All
- Show All
- Public
- All
Value Members
-
final
def
!=(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
-
final
def
##(): Int
- Definition Classes
- AnyRef → Any
-
final
def
==(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
-
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.
-
final
def
asInstanceOf[T0]: T0
- Definition Classes
- Any
-
def
browse(settings: JmsBrowseSettings): Source[Message, NotUsed]
Creates a source browsing a JMS destination (which does not consume the messages) and emitting javax.jms.Message instances.
-
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
clone(): AnyRef
- Attributes
- protected[java.lang]
- Definition Classes
- AnyRef
- Annotations
- @native() @throws( ... )
-
def
create(settings: JmsConsumerSettings): Source[Message, JmsConsumerControl]
Creates a source emitting javax.jms.Message instances, and materializes a control instance to shut down the consumer.
-
final
def
eq(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
-
def
equals(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
-
def
finalize(): Unit
- Attributes
- protected[java.lang]
- Definition Classes
- AnyRef
- Annotations
- @throws( classOf[java.lang.Throwable] )
-
final
def
getClass(): Class[_]
- Definition Classes
- AnyRef → Any
- Annotations
- @native()
-
def
hashCode(): Int
- Definition Classes
- AnyRef → Any
- Annotations
- @native()
-
final
def
isInstanceOf[T0]: Boolean
- Definition Classes
- Any
-
def
mapSource(settings: JmsConsumerSettings): Source[Map[String, Any], JmsConsumerControl]
Creates a source emitting maps, and materializes a control instance to shut down the consumer.
-
final
def
ne(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
-
final
def
notify(): Unit
- Definition Classes
- AnyRef
- Annotations
- @native()
-
final
def
notifyAll(): Unit
- Definition Classes
- AnyRef
- Annotations
- @native()
-
def
objectSource(settings: JmsConsumerSettings): Source[Serializable, JmsConsumerControl]
Creates a source emitting de-serialized objects, and materializes a control instance to shut down the consumer.
-
final
def
synchronized[T0](arg0: ⇒ T0): T0
- Definition Classes
- AnyRef
-
def
textSource(settings: JmsConsumerSettings): Source[String, JmsConsumerControl]
Creates a source emitting Strings, and materializes a control instance to shut down the consumer.
-
def
toString(): String
- Definition Classes
- AnyRef → Any
-
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.
-
final
def
wait(): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws( ... )
-
final
def
wait(arg0: Long, arg1: Int): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws( ... )
-
final
def
wait(arg0: Long): Unit
- Definition Classes
- AnyRef
- Annotations
- @native() @throws( ... )