仅针对消息容器的 ActiveMQ 重新传递策略

Question

在这段代码中，我试图仅为特定主题中的消息设置重新投递策略：

    RedeliveryPolicy redeliveryPolicy = new RedeliveryPolicy();
    emailByFolioRedeliveryPolicy.setInitialRedeliveryDelay(5000);
    emailByFolioRedeliveryPolicy.setRedeliveryDelay(5000);
    emailByFolioRedeliveryPolicy.setUseExponentialBackOff(false);
    emailByFolioRedeliveryPolicy.setBackOffMultiplier(10);
    emailByFolioRedeliveryPolicy.setMaximumRedeliveries(3);

    PooledConnectionFactory connPool = new PooledConnectionFactory();
    ActiveMQConnectionFactory connectionFactory = new ActiveMQConnectionFactory("tcp://localhost:61616");

    RedeliveryPolicyMap redeliveryPolicyMap = connectionFactory.getRedeliveryPolicyMap();
    redeliveryPolicyMap.put(new ActiveMQTopic("VirtualTopic.firstTopic"), redeliveryPolicy );

    connPool.setConnectionFactory(connectionFactory);
    connPool.setCreateConnectionOnStartup(true);
    connPool.setMaxConnections(20);
    return connPool;

问题是发送到另一个主题 (VirtualTopic.secondTopic) 的消息也会受到此策略的影响，因为我可以看到第二个主题的侦听器正在处理重新传递的消息。在 RedeliveryPolicyMap 中，我添加了指定目标的策略。但由于某种原因，我无法让它按预期工作。

预期是：

• 一条新消息 A 已发布到“VirtualTopic.firstTopic”
• 一条新消息 B 已发布到“VirtualTopic.secondTopic”
• “VirtualTopic.firstTopic”上的侦听器“Consume.FIRST.VirtualTopic.firstTopic”将处理消息 A。
• “VirtualTopic.secondTopic”上的侦听器“Consume.SECOND.VirtualTopic.firstTopic”将处理消息 B。
• 如果 FIRST 侦听器失败，将在 15 分钟后重试。
• 如果 SECOND 侦听器失败，则不会发生任何事情。该消息将最终进入死信队列。

我从这个页面获取了配置：

http://activemq.apache.org/redelivery-policy.html

有人做过这样的事情吗？谢谢。

Answer 1

策略在 ActiveMQConnectionFactory 或 ActiveMQConnection 级别设置 - 如果您的策略不同，您需要在项目中相应地使用不同的连接工厂。在您提到的情况下，您需要使用自己的重新传递策略定义 2 个单独的 ActiveMQ 连接工厂。希望对你有帮助