Подписка Topi c с использованием клиента stompn go - PullRequest
Новая
       5

Подписка Topi c с использованием клиента stompn go

0 голосов
/ 08 января 2020

Я использую клиентскую библиотеку stompn go для подключения и подписки с topi c в ActiveMQ, опубликованном как STOMP. Я не вижу положения, указывающего адресата как TOPI C, и кажется, что по умолчанию подписка регистрируется в ActiveMQ как QUEUE. Есть ли какой-либо конкретный c шаг, необходимый для указания на TOPI C в спецификациях c? 


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())

    }
}

1 Ответ

0 голосов
/ 08 января 2020

Вы можете попробовать через это: 

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

Источник - https://github.com/gmallard/stompngo/blob/dev/send.go#L35

...