How can I setup listener container when is channelTransacted(true) to throw message into dead letter queue when is something wrong instead of requeue? When I do not use channelTransacted, everything works fine and I can see the message in the dead letter queue.
@Bean(name = "amqpInboundEsignRequest")
public IntegrationFlow amqpInbound(ConnectionFactory connectionFactory, PlatformTransactionManager transactionManager) {
return IntegrationFlows.from(
Amqp.inboundAdapter(connectionFactory, esignIAutoRequestQueue())
.acknowledgeMode(AcknowledgeMode.AUTO)
.messageConverter(new Jackson2JsonMessageConverter())
.autoStartup(false)
.defaultRequeueRejected(false)
//.channelTransacted(true) // dead letter does not work
//.transactionManager(transactionManager) // dead letter does not work
)
.log("amqpInbound.start-process")
.handle(p -> {
throw new RuntimeException("Something wrong!");
})
.get();
}
EDIT
These are versions of dependencies.
[INFO] +- org.springframework.boot:spring-boot-starter-amqp:jar:1.5.9.RELEASE:compile
[INFO] | +- org.springframework:spring-messaging:jar:4.3.13.RELEASE:compile
[INFO] | \- org.springframework.amqp:spring-rabbit:jar:1.7.4.RELEASE:compile
[INFO] | +- com.rabbitmq:http-client:jar:1.1.1.RELEASE:compile
[INFO] | +- com.rabbitmq:amqp-client:jar:4.0.3:compile
[INFO] | +- org.springframework.retry:spring-retry:jar:1.2.1.RELEASE:compile
[INFO] | \- org.springframework.amqp:spring-amqp:jar:1.7.4.RELEASE:compile
[INFO] +- org.springframework.boot:spring-boot-starter-integration:jar:1.5.9.RELEASE:compile
[INFO] | +- org.springframework.integration:spring-integration-core:jar:4.3.12.RELEASE:compile
[INFO] | \- org.springframework.integration:spring-integration-java-dsl:jar:1.2.3.RELEASE:compile
[INFO] | \- org.reactivestreams:reactive-streams:jar:1.0.0:compile
I would like to have transaction synchronized with the external transaction db (PlatformTransactionManager). When I set transactionManager(transactionManager) on listener container it always do requeue.