java - 如何限制activemq实例上的重新连接次数

Question

我有一个与 activemq 代理交互的 Spring JMS 应用程序。如果应用程序无法到达代理，它将无限期地重试。如何配置 activemq.xml 文件或 DefaultJmsListenerContainerFactory bean 中的某些内容，以便它不会无限期地重试？

我看到对 activemq ReconnectionPolicy 的引用，但我不确定如何在 activemq.xml 中设置它，或者是否可以在 JMS 容器工厂中设置它

Answer 1

在监听器容器工厂上设置 BackOff。

/**
 * Specify the {@link BackOff} instance to use to compute the interval
 * between recovery attempts. If the {@link BackOffExecution} implementation
 * returns {@link BackOffExecution#STOP}, this listener container will not further
 * attempt to recover.
 * <p>The {@link #setRecoveryInterval(long) recovery interval} is ignored
 * when this property is set.
 * @since 4.1
 */

ExponentialBackOff 将增加尝试之间的时间，自定义 BackOff 可以返回 BackOffExecution.STOP 并且容器将停止( ) 本身。 FixedBackOff 可以使用 maxAttempts 进行配置。

您还可以在容器注册表(或使用其 id 从注册表获取的单个容器)上调用 stop()。