From fb64156e926cfd98d0b4891543bdb47151272486 Mon Sep 17 00:00:00 2001
From: liuxiaolong <736321739@qq.com>
Date: 星期一, 13 一月 2020 16:35:24 +0800
Subject: [PATCH] fix
---
pubsub.go | 9 +++++----
1 files changed, 5 insertions(+), 4 deletions(-)
diff --git a/pubsub.go b/pubsub.go
index 491ccc2..d1b8c87 100644
--- a/pubsub.go
+++ b/pubsub.go
@@ -19,10 +19,11 @@
Topic_Event = "event" //浜嬩欢娑堟伅
)
-func NewPublisher(url string,mode int) (PubSub,error) {
- return newPub(url)
+func NewPublisher(url string,heartBeatUrl string,mode int) (PubSub,error) {
+ return newPub(url,heartBeatUrl)
}
-func NewSubscriber(url string,mode int,topics []string) (PubSub,error) {
- return newSub(url, topics)
+//processId is process Identifier,unique
+func NewSubscriber(url string,heartBeatUrl string,mode int,topics []string,processId string) (PubSub,error) {
+ return newSub(url,heartBeatUrl, topics, processId)
}
\ No newline at end of file
--
Gitblit v1.8.0