final class MqttControlImpl extends MqttControl
INTERNAL API
- Annotations
- @InternalApi()
- Alphabetic
- By Inheritance
- MqttControlImpl
- MqttControl
- AnyRef
- Any
- Hide All
- Show All
- Public
- Protected
Instance Constructors
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
- final def asInstanceOf[T0]: T0
- Definition Classes
- Any
- def clone(): AnyRef
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.CloneNotSupportedException]) @native()
- def drain(): Future[Done]
Instruct the stage to drain and then stop.
Instruct the stage to drain and then stop. The exact semantics of this depend on the particular stage.
- Definition Classes
- MqttControlImpl → MqttControl
- final def eq(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
- def equals(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef → Any
- final def getClass(): Class[_ <: AnyRef]
- Definition Classes
- AnyRef → Any
- Annotations
- @native()
- val hasConnected: Future[Done]
Completed with success if the stage's first connection attempt succeeded, otherwise fails with the exception from the connection attempt.
Completed with success if the stage's first connection attempt succeeded, otherwise fails with the exception from the connection attempt.
- Definition Classes
- MqttControlImpl → MqttControl
- def hashCode(): Int
- Definition Classes
- AnyRef → Any
- Annotations
- @native()
- final def isInstanceOf[T0]: Boolean
- Definition Classes
- Any
- 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 onDisconnection(callback: (MqttDisconnectResponse) => Unit): MqttControlImpl
Register a callback to be executed when the connection is lost to the stage (e.g.
Register a callback to be executed when the connection is lost to the stage (e.g. for instrumentation).
Callbacks are executed asynchronously and it is possible that the same callback may be executed simultaneously (therefore the callback must be concurrency-safe). The callback must also not throw, and blocking should be avoided.
It is not possible to unregister a callback. Dynamic callback registrations can be implemented in the application by, e.g., registering a single callback which sends a message to an actor.
- Definition Classes
- MqttControlImpl → MqttControl
- def onMqttConnect(callback: (Boolean, String) => Unit): MqttControlImpl
Register a callback to be executed when a server is connected to (e.g.
Register a callback to be executed when a server is connected to (e.g. for instrumentation).
The callback is passed a boolean which is true if this is a reconnection and the URI of the server connected to.
Callbacks are executed asynchronously and it is possible that the same callback may be executed simultaneously (therefore the callback must be concurrency-safe). The callback must also not throw, and blocking should be avoided.
It is not possible to unregister a callback. Dynamic callback registrations can be implemented in the application by, e.g., registering a single callback which sends a message to an actor.
- Definition Classes
- MqttControlImpl → MqttControl
- def onMqttError(callback: (MqttException) => Unit): MqttControlImpl
Register a callback to be executed if an error is raised by the underlying client (e.g.
Register a callback to be executed if an error is raised by the underlying client (e.g. for instrumentation).
Callbacks are executed asynchronously and it is possible that the same callback may be executed simultaneously (therefore the callback must be concurrency-safe). The callback must also not throw, and blocking should be avoided.
It is not possible to unregister a callback. Dynamic callback registrations can be implemented in the application by, e.g., registering a single callback which sends a message to an actor.
- Definition Classes
- MqttControlImpl → MqttControl
- def shutdown(): Future[Done]
Instruct the stage to stop immediately without draining.
Instruct the stage to stop immediately without draining. The exact semantics of this depend on the particular stage.
- Definition Classes
- MqttControlImpl → MqttControl
- final def synchronized[T0](arg0: => T0): T0
- Definition Classes
- AnyRef
- def toString(): String
- Definition Classes
- AnyRef → Any
- final def wait(): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException])
- final def wait(arg0: Long, arg1: Int): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException])
- final def wait(arg0: Long): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException]) @native()
- val whenShutdown: Future[Done]
Completed when the stage has shutdown.
Completed when the stage has shutdown.
- Definition Classes
- MqttControlImpl → MqttControl