consume

src/event/socket.rs

@@ -13,7 +13,7 @@ pub enum EventType {
     CleanSessionEvent = 23,
 
     // 消费事件
-    Consume = 30,
+    ConsumeEvent = 30,
 }
 
 #[derive(Debug, Clone, Deserialize, Serialize, Default)]

src/socket/event.rs

@@ -158,7 +158,7 @@ pub trait ConsumeEvent {
         info: &TokenInfo,
         header: Header,
         status: Status,
-        desc: impl AsRef<str>,
+        extra: Option<impl AsRef<str>>,
     ) -> SocketEvent;
 }
 
@@ -167,8 +167,13 @@ impl ConsumeEvent for SocketEvent {
         info: &TokenInfo,
         header: Header,
         status: Status,
-        desc: impl AsRef<str>,
+        extra: Option<impl AsRef<str>>,
     ) -> SocketEvent {
+        let desc = if status.eq(&Status::Success) {
+            "消息消费成功"
+        } else {
+            "消息消费失败"
+        };
         let Header(msg_id, msg_ty, qos) = header;
         SocketEvent {
             seller_id: Some(info.seller_id),
@@ -178,14 +183,14 @@ impl ConsumeEvent for SocketEvent {
             version: Some(info.version),
             version_desc: info.version_desc.clone(),
             event: "消费事件".to_string(),
-            event_ty: EventType::PublishEvent as i32,
+            event_ty: EventType::ConsumeEvent as i32,
             key: None,
             qos: Some(qos as i32),
             msg_id: Some(msg_id),
             msg_ty: Some(msg_ty),
             status: status as i32,
-            desc: desc.as_ref().to_string(),
-            extra: None,
+            desc: desc.to_string(),
+            extra: extra.map(|s| s.as_ref().to_string()),
         }
     }
 }