如何在Activemq中阻止邮件在重新传递后转到死LetterQueue(DLQ)策略
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);
}
共有1个答案
问题是--你想用它们做什么？
在所有的重新交付尝试都用尽后就把它们扔掉？
配置丢弃插件
<deadLetterStrategy>
<discarding/>
</deadLetterStrategy>
PolicyEntry policy = new PolicyEntry();
policy.setDeadLetterStrategy(new DiscardingDeadLetterStrategy());
PolicyMap policyMap = new PolicyMap();
policyMap.setDefaultEntry(policy);
broker.setDestinationPolicy(policyMap);
-
我有一个JMS队列，在那里我可以获得几种类型的消息。所有消息都是对象消息。我让Spring DMLC处理它们，并尝试将它们传递到外部endpoint。 每种消息类型都与不同的endpoint相关联。 如果消息必须传递到1个或多个endpoint，我认为阻塞使用者对我没有帮助。 我找不到任何非阻塞消费者的信息，我想知道它是否真的帮助我解决我的问题。
-
我试图从ActiveMQ队列中提取消息并将其传递给Websphere MQ队列。 我正在使用WSO2，因为最终我们会希望使用它给我们的所有功能。 问题似乎在于WSO2试图将ActiveMQ消息Id作为相关Id直接传递给Websphere MQ，这是错误的格式。 WSO2代理服务配置 Axis2.xml传输接收器 xml传输发送程序 因此，从活动MQ到Websphere MQ相关Id的映射是有问题的
-
2FE552B7-53B1-4E4A-AFFF-3AEF8FE9D05B-----WebKitFormBoundaryLH8FJWGYEEVTCJMA内容-配置：表单-数据；name=“sample test file.pdf”；filename=“sample test file.pdf”content-type：application/pdf
-
我的骆驼上下文文件如下所示： 我在应用程序中的各种不同endpoint之间有几条其他路由，它们需要重新传递配置，并且按照预期的方式运行。但是，这个特定的路由类型（从文件到队列）似乎并不遵循我配置的任何重新传递策略。当我关闭ActiveMQ代理时，路由会尝试每6秒重新传递一次文件。： 10:54:17,088 WARN c_demo%5GenericFileOnCompletion 105-org.
-
我正在使用apacheMQ作为队列管理器。我使用Spring的DefaultMessageListenerContainer来使用消息。我已经对它进行了配置，以便它有一个事务：
-
我正在设计一种机制来处理消费者没有收到的消息。