From 3e9f5b869dd32441fdd3d77091cb33ef4301f244 Mon Sep 17 00:00:00 2001
From: lichao <lichao@aiotlink.com>
Date: 星期二, 06 四月 2021 20:26:20 +0800
Subject: [PATCH] use BHCenter.

---
 src/pubsub.cpp |    4 ++--
 1 files changed, 2 insertions(+), 2 deletions(-)

diff --git a/src/pubsub.cpp b/src/pubsub.cpp
index 520c006..0266c86 100644
--- a/src/pubsub.cpp
+++ b/src/pubsub.cpp
@@ -30,7 +30,7 @@
 			return false;
 		}
 		DEFER1(imsg.Release(shm()));
-		return ShmMsgQueue::Send(shm(), BHTopicBus(), imsg, timeout_ms);
+		return ShmMsgQueue::Send(shm(), BHTopicBusAddress(), 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(BHTopicBus(), MakeSub(mq().Id(), topics), timeout_ms);
+		return mq().Send(BHTopicBusAddress(), MakeSub(mq().Id(), topics), timeout_ms);
 	} catch (...) {
 		return false;
 	}

--
Gitblit v1.8.0