ntex_mqtt/
lib.rs

1//#![deny(rust_2018_idioms, warnings, unreachable_pub)]
2#![allow(rust_2018_idioms, warnings, unreachable_pub)]
3#![allow(clippy::type_complexity)]
4
5//! MQTT Client/Server framework
6
7mod topic;
8#[macro_use]
9mod utils;
10
11pub mod error;
12pub mod v3;
13pub mod v5;
14
15mod inflight;
16mod io;
17mod payload;
18mod server;
19mod service;
20mod session;
21mod types;
22mod version;
23
24pub use self::error::{HandshakeError, MqttError, ProtocolError};
25pub use self::inflight::{InFlightService, SizedRequest};
26pub use self::payload::Payload;
27pub use self::server::MqttServer;
28pub use self::session::Session;
29pub use self::topic::{TopicFilter, TopicFilterError, TopicFilterLevel};
30pub use self::types::QoS;
31
32// http://www.iana.org/assignments/service-names-port-numbers/service-names-port-numbers.xhtml
33pub const TCP_PORT: u16 = 1883;
34pub const TLS_PORT: u16 = 8883;