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
---
main.go | 26 +++++++++++++-------------
1 files changed, 13 insertions(+), 13 deletions(-)
diff --git a/main.go b/main.go
index c01a2e1..4eec6c9 100644
--- a/main.go
+++ b/main.go
@@ -6,7 +6,7 @@
import (
"nsqclient/TST/test"
- "nsqclient/nsqcli"
+ "nsqclient/nsqclient"
"sync"
"time"
"unsafe"
@@ -14,18 +14,18 @@
//export createProducer
func createProducer(addr string) unsafe.Pointer {
- n, _ := nsqcli.NewProducer(addr)
- return nsqcli.Save(n)
+ n, _ := nsqclient.NewProducer(addr)
+ return nsqclient.Save(n)
}
//export destroyProducer
func destroyProducer(ph unsafe.Pointer) {
- nsqcli.Unref(ph)
- nsqcli.DestroyProducerPool()
+ nsqclient.Unref(ph)
+ nsqclient.DestroyProducerPool()
}
-func pcvt(ph unsafe.Pointer) nsqcli.Producer {
- return nsqcli.Restore(ph).(nsqcli.Producer)
+func pcvt(ph unsafe.Pointer) nsqclient.Producer {
+ return nsqclient.Restore(ph).(nsqclient.Producer)
}
//export publish
@@ -58,30 +58,30 @@
/////////////////////////////////////////////////////////////
type consumer struct {
- nsqcon *nsqcli.NsqConsumer
+ nsqcon *nsqclient.NsqConsumer
lck sync.Mutex
msgs [][]byte
}
//export createConsumer
func createConsumer(topic, channel string) unsafe.Pointer {
- if c, err := nsqcli.NewNsqConsumer(nil, topic, channel); err == nil {
+ if c, err := nsqclient.NewNsqConsumer(nil, topic, channel); err == nil {
con := &consumer{
nsqcon: c,
}
- return nsqcli.Save(con)
+ return nsqclient.Save(con)
}
return nil
}
func ccvt(ch unsafe.Pointer) *consumer {
- return nsqcli.Restore(ch).(*consumer)
+ return nsqclient.Restore(ch).(*consumer)
}
//export destroyConsumer
func destroyConsumer(ch unsafe.Pointer) {
- nsqcli.DestroyNsqConsumer(ccvt(ch).nsqcon)
- nsqcli.Unref(ch)
+ nsqclient.DestroyNsqConsumer(ccvt(ch).nsqcon)
+ nsqclient.Unref(ch)
}
//export Run
--
Gitblit v1.8.0