问题标签 [hornetq]

我看过一篇关于hornetQ的帖子。因为他们提到了specJMS。我想知道如何将 SpecJMS 与 HornetQ 集成。我想对此进行测试。我已经尝试并安装了 SpecJMS 2008 设置并运行它，但想对 hornetQ 进行测试。

我是 HornetQ 的新手，我正在测试 hornetQ 示例。运行示例 EmbeddedExample.java 时出现异常（位于：hornetq-2.2.5.Final\examples\core\embedded\src\org\hornetq\core\example）。我在那个例子中做了一些改变并得到了异常。我所做的更改是，我将发送过程和消费过程放在了 1,00,000 次迭代的 for 循环中。代码是：

生产者工作正常，消费者在阅读 18K 或 13K 消息后给我一个例外。堆栈跟踪是：

我如何克服这个异常？

我可以获得所有 jms 主题订阅者的 ClientID 吗？我使用 Jboss AS 6 (HornetQ)。

当然，我可以向所有人发送查询并阅读回复，但我正在寻找更优雅的解决方案。

我想在核心 hornetQ 客户端中创建持久队列。问题是当我停止服务器队列并且数据将被破坏时。如何使队列持久化？我的代码是：

我已经尝试在 horntQ 中使用持久队列。我做了两个单独的例子（生产者，消费者）。我的消费者运行良好，但生产者花费了太多时间来完成发送消息。我已经分别运行以及一起运行。可能是什么问题呢？我的代码是：

我们可以控制 MDB 中的事务重试间隔吗？如果是这样，请提供示例或将我引导至文档。我们希望为 MDB 事务设置 3 分钟的时间间隔。希望是，如果查询第一次失败，那么它会在 3 分钟后重试。

我计划在我的 Web 应用程序中集成消息传递中间件。现在，我正在测试不同的消息中间件软件，如 RabbitMQ、JMS、HornetQ 等。该软件提供的示例正在运行，但没有给出预期的结果。
那么，我想知道哪些是提高性能的因素应该引起人们的注意？
开发人员应该注意哪些方面来提高中间件消息传递软件的性能？

我想在 HornetQ 中实现一个取决于节点 IP 地址的负载平衡策略。例如，如果指定的节点可用，则将其连接到该节点，否则连接到随机节点。但是，ConnectionLoadBalancingPolicy 接口只给我输入数字

假设最大值为3，我想在选择节点之前知道0,1,2的IP地址。那可能吗？

它写在 HornetQ 文档的那部分：

可以通过以下两种方式之一确定工厂负载平衡所在的服务器集：

那么如何使用发现来获取它们并将它们与我从 ConnectionLoadBalancingPolicy 获得的最大数量相匹配呢？

谢谢，萨米

由于 HornetQ 具有InVM接受器和连接器的概念，是否可以将 HornetQ Embedded配置为使同一 Tomcat 实例中的两个不同应用程序可以相互发送消息？

我看到 HornetQ 在 MBean 中保存了一些关于地址和队列的信息，所以我认为他们可以共享这些信息。

我们将 maxSession 的数量限制为 5 @ActivationConfigProperty(propertyName = "maxSession", propertyValue = "5") 如果超过 5 个并发请求，则它必须在队列中等待。是否有任何选项可以将队列中的等待消息数作为列表查看并管理队列。是否有任何 API 可以查看和管理队列。例如，如果 JMS 消息等待很长时间，使用队列管理我们可以重新发起消息，或者我们可以丢弃该消息。