From bb9a7e348892eb5c4fccb063380aa6fcd9612b71 Mon Sep 17 00:00:00 2001
From: lichao <lichao@aiotlink.com>
Date: 星期二, 06 四月 2021 17:32:35 +0800
Subject: [PATCH] server resend failed; rename msgs; refactor.
---
src/pubsub_center.cpp | 4 ++--
1 files changed, 2 insertions(+), 2 deletions(-)
diff --git a/src/pubsub_center.cpp b/src/pubsub_center.cpp
index b3af47d..698327e 100644
--- a/src/pubsub_center.cpp
+++ b/src/pubsub_center.cpp
@@ -94,7 +94,7 @@
auto &shm = socket.shm();
auto OnSubChange = [&](auto &&update) {
- DataSub sub;
+ MsgSub sub;
if (!msg.route().empty() && sub.ParseFromString(msg.body()) && !sub.topics().empty()) {
assert(sizeof(MQId) == msg.route(0).mq_id().size());
MQId client;
@@ -106,7 +106,7 @@
auto Unsub = [&](const MQId &id, auto &topics) { bus->UnsubScribe(id, topics.begin(), topics.end()); };
auto OnPublish = [&]() {
- DataPub pub;
+ MsgPub pub;
if (!pub.ParseFromString(msg.body())) {
return;
}
--
Gitblit v1.8.0