如何在Activemq中阻止邮件在重新传递后转到死LetterQueue(DLQ)策略

Question

private BrokerService createBroker() throws IOException, Exception {
         BrokerService broker = new BrokerService();KahaDBStore kaha=new KahaDBStore();
         File file =new File(path);
         TransportConnector connector = new TransportConnector();
         connector.setUri(new URI(DEFAULT_BROKER_URL));
         kaha.setDirectory(file);
         broker.addConnector(connector);
         broker.setPersistenceAdapter(kaha);
}

Answer 1

问题是--你想用它们做什么？

在所有的重新交付尝试都用尽后就把它们扔掉？

配置丢弃插件

<deadLetterStrategy>
   <discarding/>
</deadLetterStrategy>

PolicyEntry policy = new PolicyEntry();
policy.setDeadLetterStrategy(new DiscardingDeadLetterStrategy());
PolicyMap policyMap = new PolicyMap();
policyMap.setDefaultEntry(policy);
broker.setDestinationPolicy(policyMap);