Spring集成转换失败回滚JMS并且没有转发到错误通道

Question

使用Boot 2.2.2和Integration 5.2.2——当一条XML消息源于文件且未能解组（即，它不是XML）时，消息将按预期的方式进行错误通道。但是，当消息来自JMS时，通过相同的通道路由，并且无法解组，它不会被路由到errorChannel，消息会回滚到JMS。在这之后，我陷入了一个没完没了的SAXParseException循环，只为同一条消息。

我从正确的终极方式迁移JMS事件到Spring与Spring Boot的集成，遵循了这个例子。是否有一些我没有考虑的隐含交易控制？如何让Spring Integration将消息转发到errorChannel，并从传入队列提交“get”？

代码概要如下；

    @Bean
    public IntegrationFlow fileReader() {
        return IntegrationFlows
            .from(
                Files
                    .inboundAdapter( ... )
                    ...
                    .get(), e -> e.poller(Pollers.fixedDelay(1000))
            )
            .transform(new FileToStringTransformer())
            .channel("backUpChannel")
            .get();
    }

    @Bean
    public IntegrationFlow getMessageFromJms(ConnectionFactory connectionFactory, @Value("${queues.myQueue}") String myQueue) {
        return IntegrationFlows.from(
            Jms
                .messageDrivenChannelAdapter(connectionFactory)
                .destination(myQueue)
        )
        .channel("backUpChannel")
        .get();
    }

    @Bean
    public IntegrationFlow doBackUp() {
        return IntegrationFlows
            .from("backUpChannel")
            .<String>handle((payload, headers) -> {
                String uuid = headers.get(MessageHeaders.ID).toString();
                File backUpFile = new File("c:/backup/" + uuid + ".txt");
                byte[] payloadContent = payload.getBytes();
                try {
                    java.nio.file.Files.write(backUpFile.toPath(), payloadContent);
                } catch (IOException e) {
                    e.printStackTrace();
                }
                return payload;
            })
            .channel("XXX")
            .get();
    }

    @Bean
    public Jaxb2Marshaller unmarshaller() {
        Jaxb2Marshaller unmarshaller = new Jaxb2Marshaller();
        unmarshaller.setClassesToBeBound(MyClass.class);
        return unmarshaller;
    }

    @Bean
    public IntegrationFlow handleParseXml() {

        return IntegrationFlows
            .from("XXX")
            .transform(new UnmarshallingTransformer(unmarshaller()))
            .channel("YYY")
            .get();
    }

Answer 1

您需要将. errorChannel（...）添加到消息驱动的通道适配器。