我有我的数据库记录器myDatabaseLogger
,它在errorChannel
频道中没有做任何事情。 System.out.println
命令正在errorChannel
频道中工作。
我的数据库记录器myDatabaseLogger
适用于其他流程。
如何让我的数据库记录器myDatabaseLogger
在errorChannel
频道工作?
这是我的代码:
@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
日志记录并尝试对此进行更多调查。
可以在此处使用DEBUG记录器来查找问题的原因。