Skip to content

M
model-entity
Commit 606f9b71 authored by xuwencheng's avatar xuwencheng
Browse files
Options

event

parent 58b10b85
Show whitespace changes
Inline Side-by-side
Showing with 5 additions and 5 deletions
src/socket/event.rs
View file @ 606f9b71
...@@ -62,7 +62,7 @@ impl PublishEvent for SocketEvent { ...@@ -62,7 +62,7 @@ impl PublishEvent for SocketEvent {
let Header(msg_id, msg_ty, qos) = header; let Header(msg_id, msg_ty, qos) = header;
SocketEvent { SocketEvent {
seller_id: Some(info.seller_id), seller_id: Some(info.seller_id),
store_id: Some(info.seller_id), store_id: Some(info.store_id),
device_id: Some(info.device_id.clone()), device_id: Some(info.device_id.clone()),
client_type: Some(info.client_type), client_type: Some(info.client_type),
version: Some(info.version), version: Some(info.version),
...@@ -82,7 +82,7 @@ impl PublishEvent for SocketEvent { ...@@ -82,7 +82,7 @@ impl PublishEvent for SocketEvent {
fn ack(info: &TokenInfo, msg_id: i64, desc: impl AsRef<str>) -> SocketEvent { fn ack(info: &TokenInfo, msg_id: i64, desc: impl AsRef<str>) -> SocketEvent {
SocketEvent { SocketEvent {
seller_id: Some(info.seller_id), seller_id: Some(info.seller_id),
store_id: Some(info.seller_id), store_id: Some(info.store_id),
device_id: Some(info.device_id.clone()), device_id: Some(info.device_id.clone()),
client_type: Some(info.client_type), client_type: Some(info.client_type),
version: Some(info.version), version: Some(info.version),
...@@ -115,7 +115,7 @@ impl ConnectEvent for SocketEvent { ...@@ -115,7 +115,7 @@ impl ConnectEvent for SocketEvent {
}; };
SocketEvent { SocketEvent {
seller_id: Some(info.seller_id), seller_id: Some(info.seller_id),
store_id: Some(info.seller_id), store_id: Some(info.store_id),
device_id: Some(info.device_id.clone()), device_id: Some(info.device_id.clone()),
client_type: Some(info.client_type), client_type: Some(info.client_type),
version: Some(info.version), version: Some(info.version),
...@@ -135,7 +135,7 @@ impl ConnectEvent for SocketEvent { ...@@ -135,7 +135,7 @@ impl ConnectEvent for SocketEvent {
fn clean_session(info: &TokenInfo, extra: impl AsRef<str>) -> SocketEvent { fn clean_session(info: &TokenInfo, extra: impl AsRef<str>) -> SocketEvent {
SocketEvent { SocketEvent {
seller_id: Some(info.seller_id), seller_id: Some(info.seller_id),
store_id: Some(info.seller_id), store_id: Some(info.store_id),
device_id: Some(info.device_id.clone()), device_id: Some(info.device_id.clone()),
client_type: Some(info.client_type), client_type: Some(info.client_type),
version: Some(info.version), version: Some(info.version),
...@@ -177,7 +177,7 @@ impl ConsumeEvent for SocketEvent { ...@@ -177,7 +177,7 @@ impl ConsumeEvent for SocketEvent {
let Header(msg_id, msg_ty, qos) = header; let Header(msg_id, msg_ty, qos) = header;
SocketEvent { SocketEvent {
seller_id: Some(info.seller_id), seller_id: Some(info.seller_id),
store_id: Some(info.seller_id), store_id: Some(info.store_id),
device_id: Some(info.device_id.clone()), device_id: Some(info.device_id.clone()),
client_type: Some(info.client_type), client_type: Some(info.client_type),
version: Some(info.version), version: Some(info.version),
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment