【发布时间】:2018-04-23 01:18:21
【问题描述】:
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);
}
这是我的代理的配置。有人可以指定配置吗,我如何在我的重新投递策略后阻止消息进入 DLQ?
注意:我已经访问过这个,http://activemq.apache.org/message-redelivery-and-dlq-handling.html
【问题讨论】:
标签: java spring-boot activemq dead-letter