server resend failed; rename msgs; refactor.

lichao

2021-04-06 bb9a7e348892eb5c4fccb063380aa6fcd9612b71

 src/pubsub.cpp

@@ -49,7 +49,7 @@
{
   auto AsyncRecvProc = [this, tdcb](BHMsg &msg) {
      if (msg.type() == kMsgTypePublish) {
         DataPub d;
         MsgPub d;
         if (d.ParseFromString(msg.body())) {
            tdcb(d.topic(), d.data());
         }
@@ -65,7 +65,7 @@
{
   BHMsg msg;
   if (SyncRecv(msg, timeout_ms) && msg.type() == kMsgTypePublish) {
      DataPub d;
      MsgPub d;
      if (d.ParseFromString(msg.body())) {
         d.mutable_topic()->swap(topic);
         d.mutable_data()->swap(data);