我有一个MDB,在部署在glassfish上时可以使用ActiveMQ建议消息。在tomEE中使用ActiveMQ建议消息mdb
但是当我在tomEE上部署时,此MDB不消耗任何建议消息。有什么我需要打开吗?
@MessageDriven(mappedName = "ActiveMQ.Advisory.Consumer.Queue", activationConfig = {
@ActivationConfigProperty(propertyName = "destinationType", propertyValue = "javax.jms.Topic"),
@ActivationConfigProperty(propertyName = "destination", propertyValue = "ActiveMQ.Advisory.Consumer.Queue.User.*") })
public class AdvisoryMdb implements MessageListener {
private final Logger logger = LoggerFactory.getLogger(getClass().getName());
@Override
public void onMessage(Message message) {
logger.info("onMessage() {}", message);
}
}
(在TomEE我设法成功地生产和消费这些队列上,我想咨询的消息)
编辑:我测试,以对这些咨询的话题之一消耗一个独立的客户端,并得到了消息如预期。所以建议消息被成功发送,只是我的mdb不能正确地接收它们。
感谢您的关注,我设法自己解决这个问题 –
正在监听ActiveMQ.Advisory.Consumer.Queue.User。*意味着它将在匹配模式“User。*”的队列中选择消费者事件。 –