Spring Integration Java DSL: в канале ошибок базы данных не работает регистратор

Question

У меня есть регистратор базы данных 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 и попытаюсь исследовать это подробнее.

Answer 1

Регистратор DEBUG можно использовать здесь, чтобы найти причину проблемы.