object MqttCodec
Provides functions to decode bytes to various MQTT types and vice-versa. Performed in accordance with http://docs.oasis-open.org/mqtt/mqtt/v3.1.1/os/mqtt-v3.1.1-os.html with section numbers referenced accordingly.
- Source
- model.scala
Linear Supertypes
Ordering
- Alphabetic
- By Inheritance
Inherited
- MqttCodec
- AnyRef
- Any
- Hide All
- Show All
Visibility
- Public
- Protected
Type Members
- final case class BadConnectMessage(clientId: Either[DecodeError, String], willTopic: Option[Either[DecodeError, String]], willMessage: Option[Either[DecodeError, String]], username: Option[Either[DecodeError, String]], password: Option[Either[DecodeError, String]]) extends DecodeError with Product with Serializable
Something is wrong with the connect message
- final case class BadPublishMessage(topicName: Either[DecodeError, String], packetId: Option[PacketId], payload: ByteString) extends DecodeError with Product with Serializable
Something is wrong with the publish message
- final case class BadSubscribeMessage(packetId: PacketId, topicFilters: Seq[(Either[DecodeError, String], ControlPacketFlags)]) extends DecodeError with Product with Serializable
Something is wrong with the subscribe message
- final case class BadUnsubscribeMessage(packetId: PacketId, topicFilters: Seq[Either[DecodeError, String]]) extends DecodeError with Product with Serializable
Something is wrong with the unsubscribe message
- sealed abstract class DecodeError extends AnyRef
Returned by decoding when no decoding can be performed
- final case class DecodeErrorOrControlPacket(v: Either[DecodeError, ControlPacket]) extends Product with Serializable
JAVA API
- final case class InvalidPacketSize(packetSize: Int, maxPacketSize: Int) extends DecodeError with Product with Serializable
A message has been received that exceeds the maximum we have chosen--which is typically much less than what the spec permits.
A message has been received that exceeds the maximum we have chosen--which is typically much less than what the spec permits. The reported sizes do not include the fixed header size of 2 bytes.
- implicit final class MqttByteIterator extends AnyVal
- implicit final class MqttConnAck extends AnyVal
- implicit final class MqttConnect extends AnyVal
- implicit final class MqttControlPacket extends AnyVal
- implicit final class MqttDisconnect extends AnyVal
- implicit final class MqttPingReq extends AnyVal
- implicit final class MqttPingResp extends AnyVal
- implicit final class MqttPubAck extends AnyVal
- implicit final class MqttPubComp extends AnyVal
- implicit final class MqttPubRec extends AnyVal
- implicit final class MqttPubRel extends AnyVal
- implicit final class MqttPublish extends AnyVal
- implicit final class MqttRemainingLength extends AnyVal
- implicit final class MqttString extends AnyVal
- implicit final class MqttSubAck extends AnyVal
- implicit final class MqttSubscribe extends AnyVal
- implicit final class MqttUnsubAck extends AnyVal
- implicit final class MqttUnsubscribe extends AnyVal
- final case class UnknownConnectProtocol(protocolName: Either[DecodeError, String], protocolLevel: ProtocolLevel) extends DecodeError with Product with Serializable
Cannot determine the protocol name/level combination of the connect
- final case class UnknownPacketType(packetType: ControlPacketType, flags: ControlPacketFlags) extends DecodeError with Product with Serializable
Cannot determine the type/flags combination of the control packet
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()
- 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()
- 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()
- case object BufferUnderflow extends DecodeError with Product with Serializable
Not enough bytes in the byte iterator
- case object ConnectAckFlagReservedBitsSet extends DecodeError with Product with Serializable
Bits 1 to 7 are set with the Connect Ack flags
- case object ConnectFlagReservedSet extends DecodeError with Product with Serializable
Bit 0 of the connect flag was set - which it should not be as it is reserved.
- case object InvalidQoS extends DecodeError with Product with Serializable
A reserved QoS was specified