标签：java activemq apache-camel

我有一个休息服务,它将消息发送到我的队列,并将这些消息路由到文件：

from("test-jms:queue:test.queue").to("file://test");

此外,我在端点上有一个事件驱动的消费者.现在,只有在消息消耗时才会写入日志：

final Consumer consumer = endpoint.createConsumer(new Processor() {
        @Override
        public void process(Exchange exchange) throws Exception {
            String message = exchange.getIn().getBody(String.class);

            LOG.info("Message processed: " + message);
        }
    });

这一切都很好.在/ test文件夹中,我收到了我收到的每条消息的新文件,另外消费者创建了一个附加.camelLock的标记文件.使用readLock = none选项可以防止使用者按预期生成这些标记文件.

但是,消费后消息文件和标记文件都不会被删除.我可能在消费者实施中遗漏了一些东西吗？

解决方法:

当您使用内联处理器手动创建类似的消费者时,您需要在完成触发删除/移动文件等工作时手动完成Exchange的UoW.

exchange.getUnitOfWork().done(exchange);

您也可以尝试使用UnitOfWorkProducer包装处理器,UnitOfWorkProducer应该为您完成UnitOfWork的操作.

标签：java,activemq,apache-camel
来源： https://codeday.me/bug/20190612/1224805.html

本站声明： 1. iCode9 技术分享网（下文简称本站）提供的所有内容，仅供技术学习、探讨和分享；
2. 关于本站的所有留言、评论、转载及引用，纯属内容发起人的个人观点，与本站观点和立场无关；
3. 关于本站的所有言论和文字，纯属内容发起人的个人观点，与本站观点和立场无关；
4. 本站文章均是网友提供，不完全保证技术分享内容的完整性、准确性、时效性、风险性和版权归属；如您发现该文章侵犯了您的权益，可联系我们第一时间进行删除；
5. 本站为非盈利性的个人网站，所有内容不会用来进行牟利，也不会利用任何形式的广告来间接获益，纯粹是为了广大技术爱好者提供技术内容和技术思想的分享性交流网站。