使用GOLANG stompngo客户端的主题订阅

Question

我正在使用stompngo客户端库从发布为STOMP的ActiveMQ中的主题进行连接和订阅。我没有看到将目的地称为TOPIC的规定，并且似乎默认情况下，订阅已在ActiveMQ中注册为QUEUE。是否需要任何特定步骤来指向特定主题？

func subscribe() {  netconn, err := net.Dial("tcp", "localhost:61613")
    check(err)
    h := stompngo.Headers{stompngo.HK_ACCEPT_VERSION, "1.1",
        stompngo.HK_HOST, "localhost"}
    conn, err := stompngo.Connect(netconn, h)
    check(err)
    subHead := stompngo.Headers{stompngo.HK_DESTINATION, "MY_TOPIC"}
    sub, err := conn.Subscribe(subHead)
    check(err)
    for {
        msg := <-sub

        log.Println("Message : ", msg.Message.BodyString())

    }
}

Answer 1

您可以尝试通过此方法：

h := stompngo.Headers{stompngo.HK_DESTINATION, "/topic/MY_TOPIC"}

来源-https://github.com/gmallard/stompngo/blob/dev/send.go#L35