暂停 MDB 消息处理，直到 @StartupBean 完成初始化

Question

在将 JBoss 5 应用程序迁移到 JBoss AS 7 (7.1.1.FINAL) 时，我遇到了新的 JMS 消息驱动的 EJB 问题。在消息处理中，必须检查一些主数据字段。为提高性能，应使用@Singleton @StartupEJB将此主数据预加载到缓存结构中，加载数据需要大约 30 秒。

我的问题是，即使缓存尚未完全初始化，队列消息处理也会启动，从而导致消息验证错误。

我试图定义 MDB 和启动 EJB 之间的依赖关系，但据我所知，@DependsOn注释仅适用于@SingletonEJB。所以很明显我的解决方案不起作用;-)

启动bean代码：

@Singleton
@Startup
public class StartupBean {

    @PostConstruct
    void atStartup() {
        // TODO load master data cache (takes about 30 seconds)
    }

    @PreDestroy()
    void atShutdown() {
        // TODO free master data cache
    }
}

注意：我从示例中删除了真正的代码，以便于阅读:-)

消息驱动bean代码：

@MessageDriven(name="SampleMessagingBean", activationConfig = {
        @ActivationConfigProperty(propertyName="destinationType", propertyValue="javax.jms.Queue"),
        @ActivationConfigProperty(propertyName="destination", propertyValue="jms/SampleQueue"),
        @ActivationConfigProperty(propertyName = "acknowledgeMode", propertyValue = "Auto-acknowledge")
    })
    @DependsOn("StartupBean")
    public class SampleMessagingBean implements MessageListener {

    public void onMessage(Message message) {
        // TODO validate message using master data cache
    }
}

问题：如何在启动 bean 完成加载缓存之前暂停消息处理？

非常感谢任何建议:-)！

Answer 1

首先，我认为在 mdb 中注入单例 EJB 足以延迟消息消耗，但不，有时它会在 Singleton-ejb 的 @PostConstruct 完成之前开始消耗消息。所以还添加了一个方法调用，它开始工作

这适用于 glassfish，但我不明白为什么它不适用于 jboss

单例Ejb：

@Singleton
@Startup
public class SingletonBean {
    private Logger logger = Logger.getLogger(getClass().getName());

    private boolean init = false;

    public boolean isInit() {
        return init;
    }

    @PostConstruct
    public void init() {
        logger.error("singleton init start");

        //Do something that takes time here

        init = true;
        logger.error("singleton init end ");
    }
}    

和MDB：

@MessageDriven(...)
public class SomeMdb implements MessageListener {
    private Logger logger = Logger.getLogger(getClass().getName());

    @EJB
    SingletonBean sb;

    @PostConstruct
    public void init() {
        logger.error("mdb init start");
        if (!sb.isInit()) {
            logger.error("never happens");
        }
        logger.error("mdb init complete");
    }

    public void onMessage(Message message) {
        logger.error("onMessage start");
    }
}    

现在它总是在 mdb 完成 init 之前等待 SingletonBean 完成 init （如日志中所示）

19:51:51,980 [ad-pool-1; w: 3] ERROR SomeMdb       - mdb init start
19:51:52,122 [ad-pool-4848(4)] ERROR SingletonBean - singleton init start
19:51:56,316 [ad-pool-4848(4)] ERROR SingletonBean - singleton init end 
19:51:56,317 [ad-pool-1; w: 3] ERROR SomeMdb       - mdb init complete
19:51:56,317 [ad-pool-1; w: 3] ERROR SomeMdb       - onMessage start