Tag: activemq

如何使用Stomp延迟activemq消息（AMQ_SCHEDULED_DELAY）: 我正在使用节点js stompit库（ https://github.com/gdaws/node-stomp ）发送接收来自activemq的消息。问题： – 有一种情况下，我想安排一条消息发送n分钟后。我没有看到任何方式，我可以设置这个AMQ_SCHEDULED_DELAY头使用这个库（或任何其他nodejs库）有没有人使用这些消息属性进行调度。

stomp-client / stompit的node.js框架: 我将使用https://www.npmjs.com/package/stompit或https://www.npmjs.com/package/stomp-client来订阅ActiveMQ。我的问题是，是否有一个node.js框架，我可以使用它（例如Hapi，Express）？

如何使用node.js创buildMQTT客户端？: 我是MQTT的新成员，希望使用node.js来创buildMQTT客户端，它接受authentication头以连接到MQTT。连接的URL是tcp：// ip_address：61616，需要用户名和sessionId。 [服务器使用activeMQ]。请帮我解决一下这个。

Log4j JMS appender向STOMP客户端发送空消息: 我使用log4j JMS appender转发日志消息。而且我正在使用STOMP-CLIENT运行一个Node JS来监听activemq，以接收转发的日志消息现在的问题是，无论何时转发日志，都会将消息接收为空这是我的跺脚客户端代码 var Stomp = require('stomp-client'); var destination = '/topic/logTopic'; var client = new Stomp('127.0.0.1', 61613, '', ''); client.connect(function(sessionId) { client.subscribe(destination, function(body, headers) { console.log('Mesage'); console.log(body); //This is empty }); }); 这是我的Log4.j属性 log4j.rootLogger=INFO, stdout, jms ## Be sure that ActiveMQ messages are not logged to 'jms' appender log4j.logger.org.apache.activemq=INFO, stdout log4j.appender.stdout=org.apache.log4j.ConsoleAppender […]

通过node.js / stompit发送数据到ActiveMQ: 希望有人可以帮助我在这一个！任务：发送XML文件到ActiveMQ。环境：发展： OS X 10.10.5 节点4.4.3 stompit 0.25.0 生产： Ubuntu 16.04 节点7.8.0（同样的结果也尝试了4.4.3） stompit 0.25.0 我总是这样连接。 var server1 = { 'host': 'activemq-1.server.lan' }; var server2 = { 'host': 'activemq-2.server.lan' }; var servers = [server1, server2]; var reconnectOptions = { 'maxReconnects': 10 }; var manager = new stompit.ConnectFailover(servers, reconnectOptions); 标题，我为每个帧设置： const sendHeaders = { 'destination' […]

用于ActiveMQ调用的npm模块: 什么是从nodejs进行ActiveMQ调用最好的npm库？我已经尝试过“跺脚”，但有时它会发生有线连接。每当我使用stomp端口（61613）它的工作，但是当我使用TCP端口（61616）它会引发ActiveMQ日志中的exception，说明数据包大小是最大的。

如何在Node JS中编写ActiveMQ的发件人应用程序: 我想创build实现一个JMS发送器应用程序的消息传递和创build相同的JAVA。这是我在Java中的示例代码片段。 try { factory = new ActiveMQConnectionFactory("tcp://localhost:61616"); connection = factory.createConnection(); connection.start(); session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE); destination = session.createQueue("SAMPLEQUEUE"); producer = session.createProducer(destination); try { TextMessage message = session.createTextMessage(); message.setText("hello"); producer.send(message); System.out.println("Sent: " + message.getText()); } catch (IOException e) { e.printStackTrace(); } } catch (JMSException e) { e.printStackTrace(); } 这工作正常，我也能够收到我的接收器的消息。我想在Node JS中更改发件人实现，并使其成为Node JS应用程序。在Node JS上searchActiveMQ后，我对Node JS感到陌生。 […]