Crate mqtt

MQTT protocol utilities library

Strictly implements protocol of MQTT v3.1.1

Usage

use std::io::Cursor;

use mqtt::{Encodable, Decodable};
use mqtt::packet::{VariablePacket, PublishPacket, QoSWithPacketIdentifier};
use mqtt::TopicName;

// Create a new Publish packet
let packet = PublishPacket::new(TopicName::new("mqtt/learning").unwrap(),
                                QoSWithPacketIdentifier::Level2(10),
                                b"Hello MQTT!".to_vec());

// Encode
let mut buf = Vec::new();
packet.encode(&mut buf).unwrap();
println!("Encoded: {:?}", buf);

// Decode it with known type
let mut dec_buf = Cursor::new(&buf[..]);
let decoded = PublishPacket::decode(&mut dec_buf).unwrap();
println!("Decoded: {:?}", decoded);
assert_eq!(packet, decoded);

// Auto decode by the fixed header
let mut dec_buf = Cursor::new(&buf[..]);
let auto_decode = VariablePacket::decode(&mut dec_buf).unwrap();
println!("Variable packet decode: {:?}", auto_decode);
assert_eq!(VariablePacket::PublishPacket(packet), auto_decode);

Re-exports

pub use self::encodable::Decodable;

pub use self::encodable::Encodable;

pub use self::qos::QualityOfService;

pub use self::topic_filter::TopicFilter;

pub use self::topic_filter::TopicFilterRef;

pub use self::topic_name::TopicName;

pub use self::topic_name::TopicNameRef;

Modules

control

Control packets

encodable

Encodable traits

packet

Specific packets

qos

QoS (Quality of Services)

topic_filter

Topic filter

topic_name

Topic name