JBoss 6.0 中 JMS 侦听器 (MDB) 的延迟启动

Question

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

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

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

我希望这个问题得到足够的解释，否则请询问更多信息。

提前致谢， Danny

附加信息：

• JBoss 6.0.0 Final
• HornetQ 2.2.5 Final（已经更新，因为 JBoss 的默认版本有缺陷）

侦听器：

@MessageDriven(activationConfig =
    {
            @ActivationConfigProperty(propertyName = "destinationType", propertyValue = "javax.jms.Queue"),
            @ActivationConfigProperty(propertyName = "destination", propertyValue = "/queue/SchedulerQueue")
    })
public class SchedulerQueueListener implements MessageListener {
...
@Override
public void onMessage(Message message) {
   ...
   service = (IScheduledWorkerService) new InitialContext().lookup(jndiName);
   EJobResult eJobResult = service.executeJob(message);
   ...
}

示例工作程序：

@Singleton
@LocalBinding(jndiBinding = SampleJobWorkerService.JNDI_NAME)
public class SampleJobWorkerService implements IScheduledWorkerService {

...
    @EJB(name = "SampleEJB/local")
    private ISampleEJB sampleEjb;
...
    @Override
    public EJobResult executeJob(Message message) {
    int state = sampleEjb.doSomething(message.getLongProperty(A_PROPERTY));
    }

在这种情况下，sampleEjb - 成员有时将为 null

Answer 1

1. 作为解决方法，您可以创建一个具有一定延迟的超时计时器，而不是直接从 MDB 调用 EJB。因此执行时会有一些延迟。

   在 Timer 的超时方法中，您可以调用单例 EJB，以防万一它将调用其他非单例 EJB。

2. JBoss 特定：可以尝试在发送之前在消息对象中设置属性。

   msg.setLongProperty("JMS_JBOSS_SCHEDULED_DELIVERY", (当前 + 延迟));

   其他替代方案是_JBM_SCHED_DELIVERY。

编辑：

对于第一部分，您可以进行 JTA 事务，该事务可能跨越 JMS 和 JMS。 EJB。因此故障转移和其他事项可依此处理。

您还可以增加消息对象的重新传递延迟。

<address-setting match="jms.queue.someQueue">
        <redelivery-delay>5000</redelivery-delay>
</address-setting>

Answer 2

我现在也遇到同样的麻烦。

我建议您使用 EJB 3 启动 bean 注释 @Startup 在您的单例 bean 上调用 Message 侦听器上的 startDelivery 方法。