【问题标题】:How to check socket connection is available or not in nodejs stompit如何在nodejs stompit中检查套接字连接是否可用
【发布时间】:2018-10-11 11:27:42
【问题描述】:

我在节点 js 中使用 stompit 模块连接 activeMQ。

我的问题:stompit.ConnectFailover 中无法识别代理是否已连接

这是我的代码:

var stompit = require('stompit')

var connectionManager = new stompit.ConnectFailover();

connectionManager.addServer({
  'host': 'localhost',
  'port': 61623,
  'connectHeaders':{
    ...
  }
});

var channel = new stompit.Channel(connectionManager);

var subscribeHeaders = {
    'destination': '/queue/test',
    'ack': 'client'
};


channel.subscribe(subscribeHeaders, function(error, message){
    if (error) {
        console.log(error);
        return;
    }  
});

//send . But not throw error , even broker is not started
//always trying to reconnect
sendDlQ(subscribeHeaders, 'Hello');


function sendDlQ(header, body){
     channel.send(header, body);
}

无论何时调用 send 方法,总是成功。 连broker都没有启动。

发送前如何判断broker是否连接?

【问题讨论】:

    标签: node.js activemq stomp


    【解决方案1】:

    已经可以从 stompit 库中的 Channel.js 获得连接选项

    查看if(channel._client != null && !channel._closed)

    【讨论】:

      猜你喜欢
      • 2011-02-09
      • 2018-06-10
      • 2010-10-05
      • 1970-01-01
      • 2020-04-19
      • 2012-09-06
      • 1970-01-01
      • 2018-06-27
      • 2012-11-30
      相关资源
      最近更新 更多