From d26327b3cde043a9470dcd7fea8e704ea517fdae Mon Sep 17 00:00:00 2001
From: lichao <lichao@aiotlink.com>
Date: 星期四, 01 四月 2021 19:26:57 +0800
Subject: [PATCH] add req/rep center;
---
proto/source/bhome_msg.proto | 28 ++++++++++++++++++++++++----
1 files changed, 24 insertions(+), 4 deletions(-)
diff --git a/proto/source/bhome_msg.proto b/proto/source/bhome_msg.proto
index a88780b..149d8ee 100644
--- a/proto/source/bhome_msg.proto
+++ b/proto/source/bhome_msg.proto
@@ -25,8 +25,11 @@
kMsgTypePublish = 3;
kMsgTypeSubscribe = 4;
kMsgTypeUnsubscribe = 5;
- kMsgTypeQueryTopic = 6;
- kMsgTypeQueryTopicReply = 7;
+
+ kMsgTypeProcQueryTopic = 6;
+ kMsgTypeProcQueryTopicReply = 7;
+ kMsgTypeProcRegisterTopics = 8;
+ kMsgTypeProcHeartbeat = 9;
}
message DataPub {
@@ -47,10 +50,27 @@
bytes data = 1;
}
-message DataQueryTopic {
+message ProcInfo
+{
+ bytes name = 1;
+ bytes info = 2;
+}
+
+message DataProcRegister
+{
+ ProcInfo proc = 1;
+ repeated bytes topics = 2;
+}
+
+message DataProcHeartbeat
+{
+ ProcInfo proc = 1;
+}
+
+message DataProcQueryTopic {
bytes topic = 1;
}
-message DataQueryTopicReply {
+message DataProcQueryTopicReply {
BHAddress address = 1;
}
--
Gitblit v1.8.0