问题标签 [hornetq]

hornetq 中是否有任何选项可以设置消息消费者延迟。如果是这样，请举个例子。我们的要求：我们需要 MDB 以恒定的 2 分钟延迟读取消息。

hornetq 中的任何选项都可以让 MDB 监听多个队列。如果有，请提供样品。

我正在尝试独立运行 HornetQ 服务器。但是我不知道怎么做，我下载了hornetq-2.0.0.GA并使用build.sh启动了服务器，但是我希望通过java代码启动HornetQ服务器，并且想编写一个客户端代码来编写消息进入队列并进一步从队列中读取。

请帮助我进行以下活动：

1. 想知道如何通过java代码启动HornetQ server Standalone？
2. 想编写客户端代码将消息写入和读取到队列中。

请记住我没有使用 JBoss 或 Tomcat 服务器。

我将非常感激，请做需要的。

谢谢

我正在尝试使用远程托管的 JNDI 和 HornetQ 服务器运行 HornetQ jms/queue 示例。

HornetQ 服务器在 10.0.10.102 上运行。在 10.0.2.62 上运行的客户端。服务器和客户端机器都是 Linux 机器。

我在客户端配置了client-jndi.properties文件如下： java.naming.factory.initial=org.jnp.interfaces.NamingContextFactory java.naming.provider.url=jnp://10.0.10.102:1099 java.naming.factory.url.pkgs=org.jboss.naming:org.jnp.interfaces

我在 hornetq-beans.xml 配置文件中配置了 JNDI 设置，如下所示：

我收到“拒绝连接”错误或客户端挂起查找 JNDI 服务，具体取决于我是否在服务器端 Linux 机器 (10.0.10.102) 上运行了“rmiregistry”。

如果不运行“rmiregistry”，我会在客户端收到以下错误：

当我在服务器主机上运行“rmiregistry”时，JNDI 查找挂起：

挂在这里...

知道我还需要做什么来为 JNDI 查找过程配置 JNDI 或我的 Java 环境吗？谢谢你。

在没有集群的情况下（连接了多个活动的 HornetQ 服务器），我使用以下代码来了解队列的消费者数量：

但是，如果我使用具有多个相互连接的活动 HornetQ 服务器的集群设置，则每个服务器将只返回仅连接到自身而不连接到其他服务器的消费者。

如何获取也连接到其他服务器的消费者数量？

我将 Jboss 6.1 与 Hibernate 和 HornetQ 一起使用。如果我在我的数据库中操作数据并向队列添加一条消息，该消息依赖于在我不希望在我的数据实际提交到数据库之前处理该消息之前更改的数据。所以为了避免竞争条件，我想让 HornetQ 进入我的容器管理事务，这样消息只会在全局事务也被提交时“提交”到队列中。

这可能吗 ？有什么提示吗？

我需要在 SQL Server 2008 中创建一个存储过程，它可以创建消息并将消息发布到 HornetQ。我做了一些搜索，看起来我有 2 个选项：

• 在 sql server 中注册一个可用于创建和发送消息的程序集，但是是否有一个我可以用于此目的的库，或者我们必须开发自己的库？

• 使用 HornetQ REST API 但是我不知道这是否可行，如果可以，我该怎么做？

我的最后一个问题：是否可以在 sql server 中使用消息（即使有一个每分钟运行的预定作业），如果是，如何？

谢谢

我正在开发一个 JBoss 7.0.2 实例。我们的应用程序是一场战争，消息被放入队列中。这工作正常。但是当我们通过监听器读取它时，系统会抛出异常。它正在寻找一个存在于 WEB-INF/classes 中的类。

我知道模块类加载器（如果我是对的，它是 HornetMQ）无法看到这个应用程序类并抛出异常。我不希望我的应用程序类成为服务器库的一部分。生活在战争中的那个阶级是最好的地方。

例外是：

我应该怎么做才能完成这项工作？

问候。

阿肖克

我们在集群环境中有多个 JBoss-Server 实例。对于后台任务，有一个可用的全局队列，用于管理在其中注册的所有作业。对于这个队列，每个节点上都有一个简单的侦听器 (MDB)，用于管理传入的消息。此侦听器对单例 bean 进行手动查找（无注入）并启动预定义的方法。到目前为止一切正常，但是单例 bean 中的方法使用了在某些情况下不可用的其他一些（无单例服务）。例如，如果一个节点将被重新启动并且队列中有剩余的消息（尚未处理），则消息将被侦听器拾取并且所有进一步的 bean 都为空，因此该作业会产生 NPE。是否可以在接收消息后在 JMS-Listener 中定义延迟时间，或者是否可以定义“

一种可能是将 MDB 属性“DeliveryActive”设置为 false 并在完全部署后启动 bean。是否有一种简单的工作方式以编程方式执行此操作（不在 jmx-console 中）？我找到的任何手册都会将我重定向到手动 jndi 查找。我认为必须可以为每个注释注入 Bean 并调用 startDelivery()？在应用程序中是否有这样做的好地方？

另一个提示将我带到 application.xml 中的 order 属性的初始化，因为问题可能与 JBoss 部署顺序有关（某些 EJB 将比侦听器更晚可用），但JBoss 6.0 中似乎存在错误并升级到6.1。不是一种选择。也许有一个演练？

我希望问题得到充分解释，否则请询问更多信息。

在此先感谢，丹尼

附加信息：

• JBoss 6.0.0 最终版
• HornetQ 2.2.5 Final（已经更新，因为 JBoss 的默认版本有问题）

聆听者：

样本工人：

在这种情况下，sampleEjb - 成员有时会为空

我正在尝试使用带有两台机器（比如 x.my-domain.com 和 y.my-domain.com）的静态集群来设置 hornetq 集群，其中将运行两个 hornetq 服务器实例。我将使用 ~/hornetq-2.2.5.Final/examples/jms/clustered-static-discovery/server{0,1}/hornetq-configuration.xml 中给出的默认配置，每个服务器中都有一个. 我希望这会起作用，因为它们在 server0/server1 下的配置文件中已经有不同的连接器端口/连接器名称/连接器引用。

此外，在配置目录下，有几个默认的 dir/ 文件（jboss-as-4、jboss-as-5、ra.xml、独立）。我应该删除所有这些并只放上面提到的 hornetq-configuration.xml 吗？