问题标签 [hornetq]

We are using HornetQ as JMS provider in JBoss 5.1 EAP and in general we are quite satisfied with HornetQs performance.

HornetQ dropped data replication support in 2.2.2 silently. Now, we have problems creating a HA solution with JBoss and HornetQ as the present HornetQ failover strategies aren't reliable. For example, clients have problems to reconnect to the HornetQ after the master is back online. Messages are stored in a store-and-forward queue when using a round-robin strategy and this leads to undelivered messages in a case of a node shutdown.

HornetQ is evolving, but without data replication no serious solution for a productive environment.

Which JMS provider support real production safe HA and failover capabilities in conjunction with good performance, monitoring and of course JBoss 5 interoperability?

The following test client code (using https://github.com/jmesnil/stomp-websocket) yields an exception in JBoss 7.0.1:

It also happens with the single line below:

Why does JBoss HornetQ report the following exception?

我试图弄清楚如何使用 stomp 和 hornetq 进行同步消息传递，或者如果它甚至可能的话。我有一个异步 stomp 客户端正在工作，但我看不到如何实现同步版本。

在服务器端，我的接受器如下所示：

我的听众看起来像这样：

我假设我需要在临时队列中放入一些东西，然后像使用 JMS 一样将其发回。我只是不清楚它是如何与 STOMP 一起工作的。我是否需要在客户端打开另一个与服务器端的“临时队列”相对应的 tcp 连接？

我对 Transactions 和 HornetQ 原生 API 有一个基本的疑问。

如果我的应用程序是基于 Spring 的，使用 Spring 管理的事务，我应该如何配置 HornetQ 以参与由 Spring (AOP) 管理的同一事务？

使用 JMS API 我想这很明显，因为 Spring 将 JMS 资源视为事务性资源。

但我不知道如何正确使用 nativa API。有人可以阐明这个问题吗？

非常感谢！

我们最近从 JBoss 4.2 升级到了 JBoss 6.1。新的 JMS 消息传递（现在使用 HornetQ）卡住了，其中有 15 个消费者，但处理的消息不超过 15 条。它看起来像一个确认问题，其中消息没有得到确认。它们由使用 EJB 2.0 编写的 MDB 使用，并且确认模式是自动确认（我们目前正在尝试将其升级到 2.1 以查看是否有区别）。有没有人经历过这个？有没有办法将服务器默认配置为自动确认？

bean 在容器管理的事务中。

我试图设置 Hornetq 集群。我有一台服务器和一台备份服务器。我按照用户指南中的说明配置了 configuration.xml。但我无法启动机器。

如果有人知道这一点，请帮助我.....提前谢谢.....:)

我有一个要求，我目前不知道它是否可能。如果消息包含指定的属性，我想暂时禁用 JMS 消息的开发。目前我使用 HornetQ 作为消息提供者。

让我们举个例子：

该队列包含以下三个条目：

在某个时刻，应用程序必须能够告诉 HornetQ 消息服务器，此时不应传递属于 B_CATEGORY 的消息（例如，因为 B_CATEGORY 对象的底层数据库已更新）。因此，id 为 2 的消息目前不会被传递，而 1 和 9 将被传递，因为它们对于类别对象具有不同的值。

它必须发生在 Java 代码之外，根本不需要重新启动应用程序。这可能吗？

谢谢你的帮助！

刚刚想到了解决这个问题的另一种设计方法。让我们假设第一个 Queue 包含具有各种类别的消息（顺便说一句，不可能为每个类别创建一个队列，因为它们可能很多）。这个“正常”队列是正常配置的（例如，没有过期，但是 DLQ）。

现在，如果侦听器使用这样的消息并发现它无法处理属于某个类别的消息，它会将其放入第二个队列。此队列配置了重新传递延迟和到期时间。如果现在将到期时间设置得足够高（当然不是队列溢出）并且重新传递时间不太短，那么如果上述问题没有解决方案，这应该可以解决。

当然，必须计算在无法处理类别期间可以创建多少这些队列条目。还有一个类别的这种不可用可能需要多长时间，以便可以相应地调整重新交付。

我正在尝试为我尝试替换自动构建的项目编写构建，并且我需要正确使用 FIND_JNI。

我可以进行简单的构建，但无法正确找到 jni.h

而且我需要找到一种正确的方法（无需破解）来定义 Java 包含，因为它需要可移植给其他用户。

我正在尝试启动嵌入式集群配置，但我无法这样做。我使用了在 hornetq 示例中找到的集群示例。它有效，我不会使用嵌入式 hornetq 运行示例。我不能得到任何异常，但系统死了。

这是 HornetQ 的配置文件：

我正在尝试直接实例化 JMS 资源而不使用 JNDI 到 REMOTE HORNETQ。

我在 Eclipse IDE 中运行我的测试代码。设置我的类路径以使用 HornetQ 2.2.5 库。

目标 HornetQ 是 2.1.2.Final 版本，我认为它们应该向后兼容，也许我错了？

好的，所以我已经阅读了在线文档并遵循了不使用 JNDI 连接到远程 JMS 服务器的示例。我不断收到以下异常。我不确定我错过了什么，但我相信我已经正确设置了所有内容。有人可以指出我在这里缺少什么吗？提前致谢。

JMSException：创建会话工厂失败

hornetq-configuration.xml 上的连接器是：

接受者是：

我的测试代码是： Connection connection = null;

我得到以下异常