0

Activemq.xml 使用发现代理具有以下配置

  <transportConnector name="openwire" uri="tcp://localhost:61616" discoveryUri="multicast://default?group=TestPartition"/>

我正在使用 node.js 的 stomp 模块。现在我需要连接到我的活动 mq 代理。没有得到如何使用配置的发现代理建立连接并得到以下错误

 error: Error: connect ECONNREFUSED
    at errnoException (net.js:769:11)
    at Object.afterConnect [as oncomplete] (net.js:760:19)error name: Error

events.js:71
    throw arguments[1]; // Unhandled 'error' event
               ^
Error: connect ECONNREFUSED
    at errnoException (net.js:769:11)
    at Object.afterConnect [as oncomplete] (net.js:760:19)

早些时候我使用下面的配置（没有提到组）并且能够成功建立连接

 <transportConnector name="openwire" uri="tcp://localhost:61616" discoveryUri="multicast://default"/>

我用来建立连接的代码

    var stomp = require("stomp");
    var  stompClient = new stomp.Stomp("localhost", 8161);
    var destHeaders = {
        destination: '/topic/testTopic',
        ack: 'acknowledgeResp'

    };
    client.connect();
    client.on('connected', function() {
        client.subscribe(destHeaders);
       });
4

1 回答 1

1

您正在尝试将 STOMP 客户端连接到 Openwire 传输连接器，这当然不会工作，因为它们是两种不同的协议。你需要为你的 STOMP 客户端配置一个 STOMP 传输连接器来连接。 

 <transportConnector name="stomp" uri="stomp://localhost:61613"/>
于 2012-11-14T23:48:00.107 回答