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, Either[DecodeError, Event[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 akka.util.ByteString payloads and independently produces akka.util.ByteString payloads e.g. an MQTT server.
- session
the MQTT 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, Either[DecodeError, Event[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 akka.util.ByteString payloads and independently produces akka.util.ByteString payloads e.g. an MQTT server.
- session
the MQTT 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()