使用 stompngo 客户端订阅主题答案

【问题标题】：Topic subscription using stompngo client使用 stompngo 客户端订阅主题
【发布时间】：2020-04-26 01:45:05
【问题描述】：

我正在使用 stompngo 客户端库连接并订阅 ActiveMQ 中作为 STOMP 发布的主题。我没有看到将目的地提及为 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())

    }
}

【问题讨论】：

你能像/topic/MY_TOPIC一样尝试吗？

标签： go activemq stomp

【解决方案1】：

你可以试试这个：

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

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

【讨论】：