server resend failed; rename msgs; refactor.

lichao

2021-04-06 bb9a7e348892eb5c4fccb063380aa6fcd9612b71

 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;
         }