Pub / Sub to Amazon MQ VitualTopics с помощью Stompit - PullRequest
0 голосов
/ 06 мая 2020

У меня есть приложение nodejs, которое использует AmazonMQ для обмена сообщениями. Мне нужно использовать виртуальные темы для публикации sh и подписки на сообщения. Я использую клиент Stompit для подключения к брокеру Activemq. Это код, который я использовал для публикации / подписки сообщений на VirtualTopi c.

    const frame = client.send({
       "destination": "/topic/virtualtopic.supertopic",
       "content-type":'text/plain'
        })
    frame.write('publish to supertopic')
    frame.end()


    const subscribeHeaders = {
    'destination':'/queue/virtualtopic.supertopic',
    'ack':'client-individual'
    }

    client.subscribe(subscribeHeaders, function(error,message){
        if (error){
            console.log('subscribe error : ',error.message);
        return
        }
        message.readString('utf-8',function(error,body){
            if(error){
                 console.log('read message error : ',error.message);
                 return 
             }
        console.log('received message : ', body)
        client.ack(message)
        })
   })

Но я не вижу ни одного сообщения, опубликованного в supertopi c. Я новичок в размещенных службах aws. Может кто-нибудь сказать мне, как этого добиться?

...