加入serf集群

zhangqian

2023-10-09 41a9bf370cff977ff8afe122a7610e07fa6c3b80

 nsq/consumer.go

@@ -5,12 +5,11 @@
   "apsClient/constvar"
   "apsClient/pkg/logx"
   "apsClient/pkg/nsqclient"
   "context"
   "fmt"
)

func Consume(topic, channel string) (err error) {
   c, err := nsqclient.NewNsqConsumer(context.Background(), topic, channel)
func NewConsumer(topic, channel string) (c *nsqclient.NsqConsumer, err error) {
   c, err = nsqclient.NewNsqConsumer(topic, channel)
   if err != nil {
      logx.Errorf("NewNsqConsumer err:%v", err)
      return