问题标签 [stomp]

Apache Fuse 5.5 是否完全支持 stomp 1.1？

我正在尝试从 python 客户端发送“NACK”。连接是在 1.1 版上建立的

但是当我发送“NACK”时它会抛出异常说2012-01-20 13:46:03,815 receiver ERROR Received server error - messageNACK received but connection is in v1.0 mode。

请帮助我解决这个问题。

我需要使用一些 Python STOMP 客户端来使用 stomp 协议与我的 ActiveMQ 服务器通信。我搜索了一些 Python STOMP 客户端库并找到了其中一些，但它们只实现了 STOMP 1.0。但是，我需要 STOMP 1.1 协议的一些特性，比如心跳支持，所以我正在寻找 STOMP 1.1 Python 客户端库。我们有任何 STOMP 1.1 Python 客户端库吗？

另外，是否有任何支持故障转移功能的 Python 客户端库？

[更新]看起来stomppy支持 STOMP 1.1，但我仍然没有得到任何支持自动故障转移的客户端。

使用 stomp.py (3.0.5) 和 python (2.6) 以及 Apache ActiveMQ (5.5.1)。我已经让基本示例正常工作，但现在我想将收到的消息（在 on_message() 中）返回到 MyListener 类之外的变量。

我可以想象这是一项非常标准的任务，但我的一般 python 技能还不足以弄清楚如何去做。我已经在谷歌上搜索了一个更高级的示例并阅读了全局变量，但我似乎仍然无法将消息放入变量中，而不仅仅是将其打印到屏幕上。

任何帮助，非常感谢！

我正在尝试几个用于 java 的 stomp 库（gozirra、stompj、activemq）。所有这些库的文档都很差，例如只有一个示例，我遇到了一个严重的问题：

我需要 SSL 支持。

stomp+ssl 协议存在并且被 activemq 支持，但我找不到支持它的 Java 客户端。

我使用 stomp.py 作为 ActiveMQ 与 VeriFIX 对话的客户端。Verifix 使用 JMS。

有一个 API 主题可以发送命令，还有一个 API.RESPONSE 主题可以接收响应。

只有标头到达 stomp 客户端，而不是实际的有效负载。

我似乎需要按顺序配置消息转换，以便 ActiveMQ 知道如何将消息序列化到 STOMP 客户端。

http://activemq.apache.org/stomp.html提到了 XStream (XML) 和 Jettison (JSON)

如何配置 XStream 或 Jettison？

（已编辑）解决方案：

解决方案是包含一个“转换”标头。

有效值为：jms-map-json 或 jms-map-xml

这是订阅框架的外观。

找到这个后，我仍然无法在 ActiveMQ 文档中找到它。

这在任何地方都有记录吗？

我想要做的是使用 stomp 通过 websocket 向主题发送 20-120KB 之间的消息，并引发以下错误，我试图将 requestBufferSize 和 ResponseBuffersize 增加到 512000 的值而没有任何效果。任何帮助表示赞赏。

警告 | 处理失败的 java.lang.IllegalStateException：在 org.eclipse.jetty.websocket.WebSocketConnectionD00.handle(WebSocketConnectionD00.java:164) 在 org.eclipse.jetty.websocket.WebSocketParserD00.parseNext(WebSocketParserD00.java:104) 在 org. eclipse.jetty.io.nio.SelectChannelEndPoint.handle(SelectChannelEndPoint.java:545) at org.eclipse.jetty.io.nio.SelectChannelEndPoint$1.run(SelectChannelEndPoint.java:43) at org.eclipse.jetty.util.thread .QueuedThreadPool.runJob(QueuedThreadPool.java:598) at org.eclipse.jetty.util.thread.QueuedThreadPool$3.run(QueuedThreadPool.java:533) at java.lang.Thread.run(Thread.java:722)

I'm looking for a RabbitMQ replacement in a PHP project. Two options I am considering so far are Kestrel and Qpid (if we decide to stick with AMQP (which I would like to avoid)). In RabbitMQ, you can send a message to an exchange (destination), which decides which queues or topics (in JMS terms) the message should be delivered to. What stops me from choosing a STOMP server (ActiveMQ/Apollo or HornetQ) is that I can't find out whether it is possible in STOMP to SEND a message to a destination so that the message is delivered to a number of queues (in JMS terms)? The sender is not supposed to know which queues the message should be delivered to.

Thank you.

我在 Ubuntu Linux 10.04 上安装了 Karaf (2.2.5)。在 Karaf 之上安装了 ActiveMQ 作为功能。使用 stomp 连接器创建了一个自定义代理。现在，当我尝试从 Java 客户端连接到这个 stomp 代理时，我得到“java.net.SocketTimeoutException：读取超时”

如果我将 ActiveMQ 作为独立应用程序启动，则相同的客户端可以正常工作。

提前致谢

这是我的配置：

我正在尝试使用 Perl 的 Net::Stomp 向 Active MQ 主题发送消息。另一方面，Java 客户端监视主题并从中获取消息。Active MQ 基于 Spring 框架，我在 Spring config.xml 中定义了以下内容

从 Perl 发送的消息根本没有被另一端的 Java 客户端接收。perl 代码如下所示。有什么不对吗？

我也使用过该$stomp->send方法（上面已注释掉），但它也不起作用。然后我在某处读到 STOMP 需要对消息进行构图和发送，因此我对消息进行了构图。MQ Java 侦听器适用于通过 TCP（来自其他 java 客户端）进入端口 61616 的消息，但我无法通过 61613（多个消息生产者）使其适用于 Perl。我搜索了一下，发现很多人都让它在 PHP 到 Java 上工作，但没有一个 Perl 到 Java 的例子。是否有不同的方式需要在 Java 监视器端（消费者）处理 Stomp 消息或通常的 onMessage 实现（如 TCP）应该工作？

我有一个维护应用程序全局状态的服务器。

客户端可以连接到服务器并获取有关全局状态更改的消息（发布/订阅机制以便服务器广播信息）。

然而，在启动时，客户端根本没有关于全局状态的信息，他们需要它。我想要的是对于订阅系统的任何新客户端，第一条通知消息是应用程序的完整状态。然后他们只收到有关此状态的更改：

1. 客户端连接到消息传递系统
2. 它订阅消息系统
3. 它收到的第一条消息是系统的完整状态
4. 然后，它只接收有关全局状态的更改

这个想法类似于多人游戏，新玩家必须首先获得游戏的完整状态，然后只发送游戏中的变化。

像 ActiveMQ 或 Stomp 这样的消息传递系统可以满足我的需求，因为它们是多语言的，并且可以与多个传输层一起使用。但是，没有发送完整状态的概念（或以连贯的方式累积最后的更改）。

当然，我可以轻松地以静态方式提供此状态（首先我获得完整状态，然后订阅发布/订阅系统），但是我必须注意同时可能发生的变化（我是否丢失了一些变化在处理完整状态时？在我刚刚检索到的全局状态中是否已经考虑到了这种变化？...）。但是，我失去了 Stomp 和 ActiveMQ 已经提供的多语言/多传输方面。

是否有一些现有的库/工具可以做到这一点？ActiveMQ 的某种扩展？类似于 Stomp 的东西？还是需要手工制作？