refactor.

lichao

2021-04-06 70fec55c71f707358e6dba1b551d7836e93a5c78

 src/pubsub.cpp

@@ -30,7 +30,7 @@
         return false;
      }
      DEFER1(imsg.Release(shm()));
      return ShmMsgQueue::Send(shm(), kBHTopicBus, imsg, timeout_ms);
      return ShmMsgQueue::Send(shm(), BHTopicBus(), imsg, timeout_ms);
   } catch (...) {
      return false;
   }
@@ -39,7 +39,7 @@
bool SocketSubscribe::Subscribe(const std::vector<Topic> &topics, const int timeout_ms)
{
   try {
      return mq().Send(kBHTopicBus, MakeSub(mq().Id(), topics), timeout_ms);
      return mq().Send(BHTopicBus(), MakeSub(mq().Id(), topics), timeout_ms);
   } catch (...) {
      return false;
   }