object Mqtt
- Source
- Mqtt.scala
- Alphabetic
- By Inheritance
- Mqtt
- AnyRef
- Any
- Hide All
- Show All
- Public
- Protected
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 clientSessionFlow[A](session: MqttClientSession, connectionId: ByteString): BidiFlow[Command[A], ByteString, ByteString, DecodeErrorOrEvent[A], NotUsed]
Create a bidirectional flow that maintains client session state with an MQTT endpoint.
Create a bidirectional flow that maintains client session state with an MQTT endpoint. The bidirectional flow can be joined with an endpoint flow that receives ByteString payloads and independently produces ByteString payloads e.g. an MQTT server.
- session
the client session to use
- connectionId
a identifier to distinguish the client connection so that the session can route the incoming requests
- returns
the bidirectional flow
- def clone(): AnyRef
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.CloneNotSupportedException]) @native()
- final def eq(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
- def equals(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef → Any
- def finalize(): Unit
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.Throwable])
- final def getClass(): Class[_ <: AnyRef]
- Definition Classes
- AnyRef → Any
- Annotations
- @native()
- 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 serverSessionFlow[A](session: MqttServerSession, connectionId: ByteString): BidiFlow[Command[A], ByteString, ByteString, DecodeErrorOrEvent[A], NotUsed]
Create a bidirectional flow that maintains server session state with an MQTT endpoint.
Create a bidirectional flow that maintains server session state with an MQTT endpoint. The bidirectional flow can be joined with an endpoint flow that receives ByteString payloads and independently produces ByteString payloads e.g. an MQTT server.
- session
the server session to use
- connectionId
a identifier to distinguish the client connection so that the session can route the incoming requests
- returns
the bidirectional flow
- 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()