From 1b4fc8c66026c77abf734126b4e7662e386ec0f5 Mon Sep 17 00:00:00 2001
From: zhangmeng <775834166@qq.com>
Date: 星期二, 16 五月 2023 16:50:46 +0800
Subject: [PATCH] for go get
---
TST/test/test.go | 8 ++++----
1 files changed, 4 insertions(+), 4 deletions(-)
diff --git a/TST/test/test.go b/TST/test/test.go
index 5aaf283..2e1a679 100644
--- a/TST/test/test.go
+++ b/TST/test/test.go
@@ -4,16 +4,16 @@
"context"
"fmt"
"log"
- "nsqclient/nsqcli"
+ "nsqclient/nsqclient"
"time"
)
func produce(two bool) {
- p, _ := nsqcli.NewProducer("192.168.20.108:4150")
+ p, _ := nsqclient.NewProducer("192.168.20.108:4150")
var str string
for len(str) < 32 {
- str += "cnsqcli dynamic library"
+ str += "cnsqclient dynamic library"
}
msgx := []byte(str + "--x")
msgy := []byte(str + "--y")
@@ -40,7 +40,7 @@
func consume(topic, channel string) {
ctx, cancel := context.WithCancel(context.Background())
- if c, e := nsqcli.NewNsqConsumer(ctx, topic, channel); e != nil {
+ if c, e := nsqclient.NewNsqConsumer(ctx, topic, channel); e != nil {
fmt.Println("NewNsqConsumer failed", e)
return
} else {
--
Gitblit v1.8.0