Como enviar uma mensagem do node.js para ActiveMQ utilizando STOMP

Este é um cliente escrito em Node.JS para integração com Apache ActiveMQ utilizando o protocolo STOMP. Neste exemplo o cliente node.js envia mensagens para o ActiveMQ.

Instalação

npm install stomp-client

ActiveMQ

Do lado do ActiveMQ, no arquivo etc/activemq.xml adicionar o connector:

<transportConnector name="stomp" uri="stomp://localhost:61613"/>

Exemplo do arquivo activemq.xml alterado:

<transportConnectors>
    <transportConnector uri="tcp://localhost:61616"/>
    <transportConnector uri="stomp://localhost:61613"/>
</transportConnectors>

Crie um arquivo com o nome producer.js e cole o seguinte conteúdo:

var Stomp = require('stomp-client');
 var destination = '/queue/eromqueue';
 var client = new Stomp('localhost', 61613, 'admin', 'admin');
client.connect(function(sessionId) {
 client.subscribe(destination, function(body, headers) {
 console.log('Erom >>> This is the body of a message on the subscribed queue:', body);
 });
client.publish(destination, '>>> erom <<< ');
 });

Executar

Para executar, digite no terminal:

node producer.js



Deixe uma resposta

Preencha os seus dados abaixo ou clique em um ícone para log in:

Logotipo do WordPress.com

Você está comentando utilizando sua conta WordPress.com. Sair / Alterar )

Imagem do Twitter

Você está comentando utilizando sua conta Twitter. Sair / Alterar )

Foto do Facebook

Você está comentando utilizando sua conta Facebook. Sair / Alterar )

Foto do Google+

Você está comentando utilizando sua conta Google+. Sair / Alterar )

Conectando a %s