MQTT.Encoding

Binary encoding for MQTT messages.

Documentation

writeTo :: Handle -> Message t -> IO ()

Directly write a Message to the buffer of a Handle.

putMessage :: Message t -> Builder

Generate a Builder for any Message.

Fixed Header

putMqttHeader :: MqttHeader -> Word8 -> Builder

Build a MqttHeader for the given message type.

encodeRemaining :: Int64 -> Builder

Encode the remaining length field.

Body

putBody :: MessageBody t -> Builder

Build the MessageBody for any message type.

putConnect :: Connect -> Builder

putConnAck :: ConnAck -> Builder

putPublish :: Publish -> Builder

putSubscribe :: Subscribe -> Builder

putSubAck :: SubAck -> Builder

putUnsubscribe :: Unsubscribe -> Builder

putSimple :: SimpleMsg -> Builder

Utility functions

putMsgID :: MsgID -> Builder

Build a MsgID.

putMqttText :: MqttText -> Builder

Build a length-prefixed MqttText.

putTopic :: Topic -> Builder

Build a Topic.

fromQoS :: Num a => QoS -> a

Encode a QoS.

toBit :: Num a => Bool -> a

Convert a Bool to 0 or 1.

msgType :: Num a => MessageBody t -> a

Encode the type of a MessageBody.