Tag: 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 […]
