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
  1. Alphabetic
  2. By Inheritance
Inherited
  1. MqttCodec
  2. AnyRef
  3. Any
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. Protected

Type Members

  1. 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

  2. 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

  3. 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

  4. final case class BadUnsubscribeMessage(packetId: PacketId, topicFilters: Seq[Either[DecodeError, String]]) extends DecodeError with Product with Serializable

    Something is wrong with the unsubscribe message

  5. sealed abstract class DecodeError extends AnyRef

    Returned by decoding when no decoding can be performed

  6. final case class DecodeErrorOrControlPacket(v: Either[DecodeError, ControlPacket]) extends Product with Serializable

    JAVA API

  7. 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.

  8. implicit final class MqttByteIterator extends AnyVal
  9. implicit final class MqttConnAck extends AnyVal
  10. implicit final class MqttConnect extends AnyVal
  11. implicit final class MqttControlPacket extends AnyVal
  12. implicit final class MqttDisconnect extends AnyVal
  13. implicit final class MqttPingReq extends AnyVal
  14. implicit final class MqttPingResp extends AnyVal
  15. implicit final class MqttPubAck extends AnyVal
  16. implicit final class MqttPubComp extends AnyVal
  17. implicit final class MqttPubRec extends AnyVal
  18. implicit final class MqttPubRel extends AnyVal
  19. implicit final class MqttPublish extends AnyVal
  20. implicit final class MqttRemainingLength extends AnyVal
  21. implicit final class MqttString extends AnyVal
  22. implicit final class MqttSubAck extends AnyVal
  23. implicit final class MqttSubscribe extends AnyVal
  24. implicit final class MqttUnsubAck extends AnyVal
  25. implicit final class MqttUnsubscribe extends AnyVal
  26. 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

  27. 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

  1. final def !=(arg0: Any): Boolean
    Definition Classes
    AnyRef → Any
  2. final def ##: Int
    Definition Classes
    AnyRef → Any
  3. final def ==(arg0: Any): Boolean
    Definition Classes
    AnyRef → Any
  4. final def asInstanceOf[T0]: T0
    Definition Classes
    Any
  5. def clone(): AnyRef
    Attributes
    protected[lang]
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.CloneNotSupportedException]) @native()
  6. final def eq(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  7. def equals(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef → Any
  8. def finalize(): Unit
    Attributes
    protected[lang]
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.Throwable])
  9. final def getClass(): Class[_ <: AnyRef]
    Definition Classes
    AnyRef → Any
    Annotations
    @native()
  10. def hashCode(): Int
    Definition Classes
    AnyRef → Any
    Annotations
    @native()
  11. final def isInstanceOf[T0]: Boolean
    Definition Classes
    Any
  12. final def ne(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  13. final def notify(): Unit
    Definition Classes
    AnyRef
    Annotations
    @native()
  14. final def notifyAll(): Unit
    Definition Classes
    AnyRef
    Annotations
    @native()
  15. final def synchronized[T0](arg0: => T0): T0
    Definition Classes
    AnyRef
  16. def toString(): String
    Definition Classes
    AnyRef → Any
  17. final def wait(): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.InterruptedException])
  18. final def wait(arg0: Long, arg1: Int): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.InterruptedException])
  19. final def wait(arg0: Long): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.InterruptedException]) @native()
  20. case object BufferUnderflow extends DecodeError with Product with Serializable

    Not enough bytes in the byte iterator

  21. case object ConnectAckFlagReservedBitsSet extends DecodeError with Product with Serializable

    Bits 1 to 7 are set with the Connect Ack flags

  22. 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.

  23. case object InvalidQoS extends DecodeError with Product with Serializable

    A reserved QoS was specified

Inherited from AnyRef

Inherited from Any

Ungrouped