From ba4edc18fa5e527c09e1cce4fef9439908558e5a Mon Sep 17 00:00:00 2001 From: zhangmeng <775834166@qq.com> Date: 星期四, 16 五月 2019 16:02:29 +0800 Subject: [PATCH] update deliver --- deliver | 2 +- main.go | 4 ++-- 2 files changed, 3 insertions(+), 3 deletions(-) diff --git a/deliver b/deliver index a6b23c5..8e158e6 160000 --- a/deliver +++ b/deliver @@ -1 +1 @@ -Subproject commit a6b23c5eaf5a8b9265e13d3db370d45cfcd5bc21 +Subproject commit 8e158e611ca6a3663e383d5a9b14d14eaf897736 diff --git a/main.go b/main.go index 8222aa6..4b95ff6 100644 --- a/main.go +++ b/main.go @@ -35,7 +35,7 @@ } func sender(url string, args ...interface{}) { - s := deliver.NewProducer(deliver.Mode(mode), url, args...) + s := deliver.NewListener(deliver.Mode(mode), url, args...) go senderImpl(s) @@ -47,7 +47,7 @@ } func recvImpl(url string, index int) { - c := deliver.NewConsumer(deliver.Mode(mode), url) + c := deliver.NewDialer(deliver.Mode(mode), url) var msg []byte var err error -- Gitblit v1.8.0