0

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

    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

有没有人完成过这样的事情？谢谢。

4

1 回答 1

0

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

于 2015-07-31T19:48:46.937 回答