是否可以从"ActiveMQ.Advisory.MessageConsumed.Queue.queue-name“主题接收的消息中检索consumerId?
当使用者使用来自队列的消息时,咨询消息将放置在主题ActiveMQ.Advisory.MessageConsumed.Queue.queue-name.中。在检查了从ActiveMQ.Advisory.MessageConsumed.Queue.queue-name检索到的消息之后,我意识到没有consumerId。
我为ActiveMQ.Advisory.MessageConsumed.Queue.queue-name定制的MessageListener有方法:
@Override
public void onMessage(Message message) {
ActiveMQMessage msg = (ActiveMQMessage)message;
// Retrives the MessageListener's connection which consumed a message from Advisory Topic
msg.getConnection().getClientID();
// Retrives the Producer's connection which place a message into a queue
((ActiveMQMessage)msg.getDataStructure()).getConnection().getClientID();
// How to retrive a consumerId which consumed a message from the queue?
}
我将感谢你的帮助。
发布于 2015-04-28 13:31:23
该信息在通知中不可用,只有连接ID可用。
https://stackoverflow.com/questions/29899373
复制相似问题