Spring Integration Java DSL:在错误通道中,数据库记录器无法正常工作

问题描述 投票:0回答:1

我有我的数据库记录器myDatabaseLogger,它在errorChannel频道中没有做任何事情。 System.out.println命令正在errorChannel频道中工作。

我的数据库记录器myDatabaseLogger适用于其他流程。

如何让我的数据库记录器myDatabaseLoggererrorChannel频道工作?

这是我的代码:

    @Autowired
@Qualifier("errorChannel")
private PublishSubscribeChannel errorChannel;

@Bean
public IntegrationFlow errorHandlingFlow() {
    return IntegrationFlows
            .from(errorChannel)
            .handle(myDatabaseLogger, "log")
            .handle(message -> System.out
                    .println("The error happened:" + ((MessagingException) message.getPayload()).getMessage()))
            .get();
}

编辑:

抱歉延误,刚来假期。

myDatabaseLogger类是简单的Java类,它使用存储库写入数据库,该存储库扩展了org.springframework.data.repository.CrudRepository。在errorHandlingFlow方法中,没有行被写入数据库。

我稍后会使用DEBUG日志记录并尝试对此进行更多调查。

spring-integration spring-integration-dsl
1个回答
0
投票

可以在此处使用DEBUG记录器来查找问题的原因。

© www.soinside.com 2019 - 2024. All rights reserved.