Config - application.yml
spring:
cloud:
stream:
default:
group: txGroup
contentType: application/json
consumer:
concurrency: 2
maxAttempts: 1
bindings:
output:
consumer:
group: txGroup
provisionDurableQueue: true
autoBindErrorQueue: true
errorQueueNameOverride: txError
durableSubscription: true
republishToDlq: true
=====================================================
@StreamListener(LoanProcessor.TX_ERROR)
public void txError(Message message) {
System.out.println("ERROR :: " + message.toString());
}
==================================================
String TX_ERROR = "txError";
@Input(TX_ERROR)
SubscribableChannel errors();
====================================================
@EnableBinding(LoanProcessor.class)
@SpringBootApplication
public class LoanCheckApplication {
public static final Logger log = LoggerFactory.getLogger(LoanCheckApplication.class);
public static void main(String[] args) {
SpringApplication.run(LoanCheckApplication.class, args);
log.info("The Loancheck Application has started...");
}
}
provided the code and the ACL access denied, basically i tried to create autobind error queue to one of my consumer but except for this all are working why error queue is not working