Module: Protocol::MQTT

Defined in:

lib/protocol/mqtt.rb,
lib/protocol/mqtt/vbi.rb,
lib/protocol/mqtt/codec.rb,
lib/protocol/mqtt/error.rb,
lib/protocol/mqtt/packet.rb,
lib/protocol/mqtt/version.rb,
lib/protocol/mqtt/property.rb,
lib/protocol/mqtt/connection.rb,
lib/protocol/mqtt/packet/auth.rb,
lib/protocol/mqtt/reason_codes.rb,
lib/protocol/mqtt/packet/puback.rb,
lib/protocol/mqtt/packet/pubrec.rb,
lib/protocol/mqtt/packet/pubrel.rb,
lib/protocol/mqtt/packet/suback.rb,
lib/protocol/mqtt/packet/connack.rb,
lib/protocol/mqtt/packet/connect.rb,
lib/protocol/mqtt/packet/pingreq.rb,
lib/protocol/mqtt/packet/pubcomp.rb,
lib/protocol/mqtt/packet/publish.rb,
lib/protocol/mqtt/packet/pingresp.rb,
lib/protocol/mqtt/packet/unsuback.rb,
lib/protocol/mqtt/packet/subscribe.rb,
lib/protocol/mqtt/packet/disconnect.rb,
lib/protocol/mqtt/packet/unsubscribe.rb

Overview

MQTT wire codec. Implements MQTT 3.1.1 (OASIS 2014) and MQTT 5.0 (OASIS 2019). Pure codec: encode/decode of packets and primitives. The only IO coupling is Protocol::MQTT::Connection, which reads and writes packets over an IO::Stream.

Defined Under Namespace

Modules: Codec, Property, ReasonCodes, VBI Classes: ClosedError, Connection, Error, MalformedPacket, Packet, ProtocolError

Constant Summary

VERSION =

"0.1.0"