我有一個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。*」的隊列中選擇消費者事件。 –