From 9731130d8be7adc56010f0744ba4a6358d311110 Mon Sep 17 00:00:00 2001
From: zhangmeng <775834166@qq.com>
Date: 星期二, 16 五月 2023 16:48:57 +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 4eec6c9..c01a2e1 100644
--- a/main.go
+++ b/main.go
@@ -6,7 +6,7 @@
import (
"nsqclient/TST/test"
- "nsqclient/nsqclient"
+ "nsqclient/nsqcli"
"sync"
"time"
"unsafe"
@@ -14,18 +14,18 @@
//export createProducer
func createProducer(addr string) unsafe.Pointer {
- n, _ := nsqclient.NewProducer(addr)
- return nsqclient.Save(n)
+ n, _ := nsqcli.NewProducer(addr)
+ return nsqcli.Save(n)
}
//export destroyProducer
func destroyProducer(ph unsafe.Pointer) {
- nsqclient.Unref(ph)
- nsqclient.DestroyProducerPool()
+ nsqcli.Unref(ph)
+ nsqcli.DestroyProducerPool()
}
-func pcvt(ph unsafe.Pointer) nsqclient.Producer {
- return nsqclient.Restore(ph).(nsqclient.Producer)
+func pcvt(ph unsafe.Pointer) nsqcli.Producer {
+ return nsqcli.Restore(ph).(nsqcli.Producer)
}
//export publish
@@ -58,30 +58,30 @@
/////////////////////////////////////////////////////////////
type consumer struct {
- nsqcon *nsqclient.NsqConsumer
+ nsqcon *nsqcli.NsqConsumer
lck sync.Mutex
msgs [][]byte
}
//export createConsumer
func createConsumer(topic, channel string) unsafe.Pointer {
- if c, err := nsqclient.NewNsqConsumer(nil, topic, channel); err == nil {
+ if c, err := nsqcli.NewNsqConsumer(nil, topic, channel); err == nil {
con := &consumer{
nsqcon: c,
}
- return nsqclient.Save(con)
+ return nsqcli.Save(con)
}
return nil
}
func ccvt(ch unsafe.Pointer) *consumer {
- return nsqclient.Restore(ch).(*consumer)
+ return nsqcli.Restore(ch).(*consumer)
}
//export destroyConsumer
func destroyConsumer(ch unsafe.Pointer) {
- nsqclient.DestroyNsqConsumer(ccvt(ch).nsqcon)
- nsqclient.Unref(ch)
+ nsqcli.DestroyNsqConsumer(ccvt(ch).nsqcon)
+ nsqcli.Unref(ch)
}
//export Run
--
Gitblit v1.8.0