ActiveMQ

Question

是否可以从 "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?
}

我会很感激你的帮助。

Answer 1

咨询中没有该信息，只有连接 ID 可用。

ActiveMQ - 如何从 ActiveMQ.Advisory.MessageConsumed 的消息中检索消费者 ID

ActiveMQ - How to retrive consumerId from message from ActiveMQ.Advisory.MessageConsumed