Apache QPID JMS客户端-设置预回迁不起作用

Question

我使用如下URI配置了一个JmsConnectionFactory：

故障切换：(amqps://11.22.33.44?amqp.idleTimeout=120000

请注意jms。预回迁策略。all=10参数，根据官方文件

... 控制远程对等方可以发送到客户端并保存在每个使用者实例的预回迁缓冲区中的消息数量。

所以我应该不会在客户端中看到超过10条消息，对吧？好吧，那不起作用。

我最终使用反射来定期打印消息队列。每个JmsMessageConsumer的size（）：

MessageConsumer messageConsumer = ...
Field field = JmsMessageConsumer.class.getDeclaredField("messageQueue");
field.setAccessible(true);
MessageQueue q = (MessageQueue) field.get(messageConsumer);
Executors.newScheduledThreadPool(1).scheduleAtFixedRate(() -> System.out.println(q.size()), 10, 10, TimeUnit.SECONDS);

当我的消息处理程序很慢（或被阻塞）时，我看到队列大小略小于1000条消息，这是默认的预取大小。

那么，这是一个bug吗？如何设置不同的预取大小？

我正在使用qpid jms客户端，版本为0.27.0。

Answer 1

您的URI不正确，应为：

failover://(amqps://11.22.33.44?amqp.idleTimeout=120000&transport.tcpKeepAlive=true)
    ?jms.prefetchPolicy.all=10&failover.maxReconnectAttempts=20

JMS选项是全局的，因此它们与故障切换选项一起应用于URI的最外层。包装的AMQP连接URI仅包含控制每个特定连接的传输选项。

Answer 2

想出来了。

JmsConnectionFactory有一个JmsPrefetchPolicy。我不知道应该如何使用URI参数进行设置，但可以使用JmsConnectionFactory进行设置。setPrefetchPolicy（）如下所示：

JmsConnectionFactory cf = ...
JmsDefaultPrefetchPolicy prefetchPolicy = new JmsDefaultPrefetchPolicy();
prefetchPolicy.setAll(123); // Set prefetch size here
cf.setPrefetchPolicy(prefetchPolicy);

在任何地方都没有看到这方面的记录。