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
- Alphabetic
- By Inheritance
- MqttCodec
- AnyRef
- Any
- Hide All
- Show All
- Public
- All
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
-
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
-
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[java.lang]
- Definition Classes
- AnyRef
- Annotations
- @native() @HotSpotIntrinsicCandidate() @throws( ... )
-
final
def
eq(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
-
def
equals(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
-
final
def
getClass(): Class[_]
- Definition Classes
- AnyRef → Any
- Annotations
- @native() @HotSpotIntrinsicCandidate()
-
def
hashCode(): Int
- Definition Classes
- AnyRef → Any
- Annotations
- @native() @HotSpotIntrinsicCandidate()
-
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() @HotSpotIntrinsicCandidate()
-
final
def
notifyAll(): Unit
- Definition Classes
- AnyRef
- Annotations
- @native() @HotSpotIntrinsicCandidate()
-
final
def
synchronized[T0](arg0: ⇒ T0): T0
- Definition Classes
- AnyRef
-
def
toString(): String
- Definition Classes
- AnyRef → Any
-
final
def
wait(arg0: Long, arg1: Int): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws( ... )
-
final
def
wait(arg0: Long): Unit
- Definition Classes
- AnyRef
- Annotations
- @native() @throws( ... )
-
final
def
wait(): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws( ... )
-
object
BufferUnderflow extends DecodeError with Product with Serializable
Not enough bytes in the byte iterator
-
object
ConnectAckFlagReservedBitsSet extends DecodeError with Product with Serializable
Bits 1 to 7 are set with the Connect Ack flags
-
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.
-
object
InvalidQoS extends DecodeError with Product with Serializable
A reserved QoS was specified