lichao
2021-04-28 a6f67b4249525089fb97eb9418c7014f66c2a000
src/topic_node.cpp
@@ -389,7 +389,7 @@
      BHAddress addr;
      if (ClientQueryRPCTopic(request.topic(), addr, timeout_ms)) {
         printf("node: %ld, topic dest: %ld\n", SockNode().id(), addr.mq_id());
         // printf("node: %ld, topic dest: %ld\n", SockNode().id(), addr.mq_id());
         BHMsgHead head(InitMsgHead(GetType(request), proc_id(), ssn()));
         AddRoute(head, sock.id());
         head.set_topic(request.topic());