ActiveMQ 日志代理插件

Question

我正在使用 ActiveMQ 的 logging broker 插件 并且正在测试它并遇到以下问题：

以下方法什么时候调用？

1. messageConsumed

2. messageDelivered

3. messagePull

Javadoc 给出了一行描述，但没有用。我无法观察上述方法的日志消息，因此我很好奇。我可以通过以下方法查看日志消息：

send

、

preprocessdispatch

、

postprocessdispatch

在我的日志中。

Answer 1

以下方法什么时候调用？

1. messageConsumed - 通常在客户端确认消息时调用
2. messageDelivered - 当客户端发送一个已交付的 ACK 时调用，这意味着消息已被客户端处理但尚未确认。
3. messagePull - 当具有零大小 prefecth 值的消费者启动从代理拉取消息时调用。

Answer 2

上面的

3 方法只有在队列上设置

advisoryForConsumed=true

时才会触发。 例如。样品。

<bean class="org.apache.activemq.broker.region.policy.PolicyEntry">
  <property name="queue" value="_testEvent" />
  <property name="advisoryForConsumed" value="true" />
</bean>