0

我正在尝试使用"github.com/nats-io/go-nats"包与云中的 NAT 服务器通信。

我是这样设置的：

nc, err := nats.Connect(natsServerAddress)
if err != nil {
    log.Fatal(err)
} else {
    natsConn = nc
}

之后我订阅了队列： 

natsConn.Subscribe(natsRawSimDataQueue, func(m *nats.Msg) {
        fmt.Printf("Received a message: %s\n", string(m.Data))
})

我的实际问题是，订阅似乎没有效果。偶然我发现订阅处理程序在我发布至少一条消息后被触发。因此，当订阅者也是发布者时，它似乎可以工作。这是发布的代码：

// push data to NATS Queue
    natsConn.Publish(natsRawSimDataQueue, []byte("{\"msg\": \"Hello Listener\"}"))

有谁知道这个问题来自哪里？

4

0 回答 0