Articles of stomp

如何使用Stomp延迟activemq消息(AMQ_SCHEDULED_DELAY)

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

RabbitMQ通过websocket Stomp:无法检索排队的消息

我正在使用RabbitMQ Stomp的耐用订阅(文档在这里 )。 根据文档,当客户重新连接(订阅)相同的ID,他应该得到所有排队的消息。 但是,即使消息在服务器端排队,我也无法取回任何东西。 以下是我正在使用的代码: RabbitMQ版本:3.6.0 客户代码: var sock; var stomp; var messageCount = 0; var stompConnect = function() { sock = new SockJS(options.url); stomp = Stomp.over(sock); stomp.connect({}, function(frame) { debug('Connected: ', frame); console.log(frame); var id = stomp.subscribe('<url>' + options.source + "." + options.type + "." + options.id, function(d) { console.log(messageCount); messageCount = messageCount […]

stomp nodejs不发送连接头

我有一个超级简单的nodejs应用程序使用stomp连接到使用websockets的服务器。 问题是应用程序不是发送我告诉它发送的标题。 文档和示例不能更清楚地说明如何发送标题,所以我不知道为什么我没有看到我的wirehark。 var Stomp = require('stompjs'); var client = Stomp.overWS('ws://localhost:8080/web/wsendpoint'); var headers = { login: 'mylogin', passcode: 'mypasscode', // additional header 'Auth-Token': 'token' }; client.connect(headers, connectCallback); var connectCallback = function(frame) { alert('connected'); }; 这连接好,但标题似乎被忽略。 任何人都知道这是为什么?

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中编写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感到陌生。 […]

从STOMP / AMQP中select哪一个?

我使用node.js作为jms topic的客户端。有两个协议可用于在Topic上进行连接。 这些是Stomp和AMQP。 我在http://en.wikipedia.org/wiki/Advanced_Message_Queuing_Protocol和http://en.wikipedia.org/wiki/Streaming_Text_Oriented_Messaging_Protocol上了解他们的简介。 两者似乎都是有线协议,即通过networking作为八位字节stream发送的数据。我没有发现任何一个应该被优选的具体原因。 如果有人能阐明它,这将是有益的。 还有一点是协议引以为傲的说他们互通。 互操作术语意味着如果有人想要脱离特定的消息代理实现说apache主动MQ,而是想要插入Websphere MQ,过渡将是平稳的(既提供支持AMQP / STOMP或任何其他有线协议)?

开始了解networking套接字和http请求(和STOMP)

我最近join了一个新的项目,我负责使用networking套接字来实现stream数据。 这个想法是目前通过HTTP请求(以RESTful的方式)暴露的信息,他们希望通过networking套接字暴露。 在过去的48个小时里,我做了一些关于networking套接字和STOMP的研究,并希望得到以下几点的解释: 因此,对于客户端和服务器通过Web套接字而不是通过HTTP请求/响应进行连接,他们首先需要同意在它们之间build立一个Web套接字连接。 这是通过HTTP GET完成一个唯一的标头传递,说他们要使用一个Web套接字连接,而不是? 理论上说,有一大堆不同的数据通过一些API暴露给浏览器。 想象一下,有很多不同的HTTP请求可以做成GET,POST,DELETE。 所以要把所有这些信息的某些部分通过一个web套接字进行stream式传输,是简单地改变每个资源的当前GET请求来检查这个特殊的websocket头部是否在那里,然后做一些事情? 或者还有其他的东西需要通过networking套接字来暴露某些数据。 如果你从HTTP请求初始化套接字,我可能会误解HTTP和套接字的关系。 我认为这是我的两个主要问题,我相信这些答案将会指引我继续学习更多关于这个主题的正确方向。 我正在试图find任何好的示例代码示例,但我正试图理解这一点,足以在一周内实现。

在Node.js应用程序中自动重新连接Stomp.js

我正在使用Node.js和Express编写的应用程序,我试图使用Stomp.js客户端连接到ActiveMQ服务器。 我可以使用Stomp将应用程序连接到ActiveMQ,但是我无法让系统在连接失败时自动重新连接。 看起来只有当连接初始成功,然后被切断时才调用失败函数,但是如果在Node应用程序启动时ActiveMQ已经closures,我会看到certificate失败函数被调用的错误消息。 var Stomp = require('stompjs'); var stompClient = Stomp.overTCP('localhost', 61612); var stompStatus = false; var stompSuccessCallback = function (frame) { stompStatus = true; console.log('STOMP: Connection successful'); }; var stompFailureCallback = function (error) { stompStatus = false; console.log('STOMP: ' + error); setTimeout(stompConnect, 10000); console.log('STOMP: Reconecting in 10 seconds'); }; function stompConnect() { console.log('STOMP: Attempting […]