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

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

  28. final case class BadSubAckMessage(packetId: PacketId, returnCodes: Seq[ControlPacketFlags]) extends DecodeError with Product with Serializable

    Unable to subscribe at the requested QoS

    Unable to subscribe at the requested QoS

    Annotations
    @deprecated
    Deprecated

    (Since version 1.1.1) this message was never able to be returned - always use SubAck to test subscribed QoS

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( ... ) @native() @HotSpotIntrinsicCandidate()
  6. final def eq(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  7. def equals(arg0: Any): Boolean
    Definition Classes
    AnyRef → Any
  8. final def getClass(): Class[_]
    Definition Classes
    AnyRef → Any
    Annotations
    @native() @HotSpotIntrinsicCandidate()
  9. def hashCode(): Int
    Definition Classes
    AnyRef → Any
    Annotations
    @native() @HotSpotIntrinsicCandidate()
  10. final def isInstanceOf[T0]: Boolean
    Definition Classes
    Any
  11. final def ne(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  12. final def notify(): Unit
    Definition Classes
    AnyRef
    Annotations
    @native() @HotSpotIntrinsicCandidate()
  13. final def notifyAll(): Unit
    Definition Classes
    AnyRef
    Annotations
    @native() @HotSpotIntrinsicCandidate()
  14. final def synchronized[T0](arg0: ⇒ T0): T0
    Definition Classes
    AnyRef
  15. def toString(): String
    Definition Classes
    AnyRef → Any
  16. final def wait(arg0: Long, arg1: Int): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )
  17. final def wait(arg0: Long): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws( ... ) @native()
  18. final def wait(): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )
  19. object BufferUnderflow extends DecodeError with Product with Serializable

    Not enough bytes in the byte iterator

  20. object ConnectAckFlagReservedBitsSet extends DecodeError with Product with Serializable

    Bits 1 to 7 are set with the Connect Ack flags

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

  22. object InvalidQoS extends DecodeError with Product with Serializable

    A reserved QoS was specified

Deprecated Value Members

  1. def finalize(): Unit
    Attributes
    protected[lang]
    Definition Classes
    AnyRef
    Annotations
    @throws( classOf[java.lang.Throwable] ) @Deprecated @deprecated
    Deprecated

    (Since version ) see corresponding Javadoc for more information.

Inherited from AnyRef

Inherited from Any

Ungrouped