java - SpringIntegration 从队列中删除消息而不进行处理

Question

我们的应用程序中有一个JMS关闭队列，需要在特定事件上使用 Spring 上下文关闭正在运行的节点。

为了正确关闭正在运行的ApplicationContext而无需在启动时再次处理此“关闭”消息，我们需要有一个单独的终止Thread，以确保在我们终止ApplicationContext之前已处理该消息。

有没有办法避免额外杀死Thread？

例如：配置SpringIntegration流以标记消息已读，在从Queue读取消息后立即忽略它可能的处理失败。

Answer 1

如果您将 kill 消息路由到ExecutorChannel(or QueueChannel)，则消息将被移交给另一个线程，并且事务将立即提交。