consume

Cargo.toml

@@ -8,6 +8,7 @@ default = []
 socket = ["rmp", "rmp-serde", "bytes", "flate2"]
 paidui = []
 login = []
+client = ["socket"]
 
 [dependencies]
 anyhow = { version = "1", features = ["std"], default-features = false }

src/client/mod.rs

+use serde::{Deserialize, Serialize};
+
+use crate::socket::protocol::Qos;
+
+#[derive(Debug, Clone, Deserialize, Serialize)]
+pub struct PublishMessage {
+    #[serde(rename = "message_id")]
+    pub id: i64,
+    #[serde(rename = "business_type")]
+    pub ty: i32,
+    pub qos: Qos,
+    pub data: Option<String>,
+}
+
+impl PublishMessage {
+    /// Creates new header given it's name and value.
+    pub fn new(id: i64, ty: i32, qos: Qos, data: Option<String>) -> Self {
+        Self { id, ty, qos, data }
+    }
+}
\ No newline at end of file

src/lib.rs

@@ -7,6 +7,8 @@ pub mod paidui;
 pub mod serde;
 #[cfg(feature = "socket")]
 pub mod socket;
+#[cfg(feature = "client")]
+pub mod client;
 
 #[cfg(test)]
 mod tests {