Интеграция с Spring - Как заставить сообщение выжить в хранилище сообщений jdb c в случае ошибки или / и завершить работу в обработчике потребления

Question

У меня есть поток, который сохраняет сообщения в хранилище сообщений jdb c:

...
.channel { c -> c.queue(jdbcChannelMessageStore, "persist") }
.handle(MessageHandler { 
                        Thread.sleep(3000); 
                        throw RuntimeException() 
} ) { e -> e.poller { it.fixedDelay(1000)} }

Как сделать так, чтобы сообщение не удалялось до успешного завершения hanler?

Answer 1

Сделать опрашивающее устройство .transactional(), чтобы нисходящий поток выполнялся в транзакции; удаление не будет выполнено, пока поток не закончится (или не будет передан другому потоку).