Packages

trait JmsConsumerControl extends KillSwitch

Handle to shut down consumers and to inspect the connectivity to the JMS broker.

Source
JmsConnectorState.scala
Linear Supertypes
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. JmsConsumerControl
  2. KillSwitch
  3. AnyRef
  4. Any
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. Protected

Abstract Value Members

  1. abstract def abort(ex: Throwable): Unit
    Definition Classes
    KillSwitch
  2. abstract def connectorState: Source[JmsConnectorState, NotUsed]

    source that provides connector status change information.

    source that provides connector status change information. Only the most recent connector state is buffered if the source is not consumed.

  3. abstract def shutdown(): Unit
    Definition Classes
    KillSwitch