|
|
@@ -1,11 +1,11 @@
|
|
|
package server
|
|
|
|
|
|
import (
|
|
|
- "log"
|
|
|
"sync"
|
|
|
|
|
|
"github.com/nats-io/nats.go"
|
|
|
"go.uber.org/zap"
|
|
|
+ "x.sikey.com.cn/serverx/natx"
|
|
|
)
|
|
|
|
|
|
const (
|
|
|
@@ -35,12 +35,7 @@ type natsMessage struct {
|
|
|
}
|
|
|
|
|
|
func NewNats(addr string) *Nats {
|
|
|
- nc, err := nats.Connect(addr)
|
|
|
- if err != nil {
|
|
|
- log.Fatalln(err)
|
|
|
- }
|
|
|
- // nc.Drain()
|
|
|
-
|
|
|
+ nc := natx.GetConnect()
|
|
|
n := &Nats{
|
|
|
nc: nc,
|
|
|
mutex: sync.RWMutex{},
|
|
|
@@ -51,7 +46,7 @@ func NewNats(addr string) *Nats {
|
|
|
Unsubscribe: make(chan *subscriber),
|
|
|
}
|
|
|
|
|
|
- _, err = nc.ChanSubscribe(subject, n.ch)
|
|
|
+ _, err := nc.ChanSubscribe(subject, n.ch)
|
|
|
if err != nil {
|
|
|
zap.L().Error("unable to start", zap.Error(err))
|
|
|
}
|
