Skip to content

Commit f185367

Browse files
committed
revert: add listener log
1 parent 46dbcc5 commit f185367

1 file changed

Lines changed: 6 additions & 0 deletions

File tree

async/async-rabbit/src/main/java/org/reactivecommons/async/rabbit/listeners/GenericMessageListener.java

Lines changed: 6 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -90,6 +90,12 @@ public synchronized void startListener() {
9090
return;
9191
}
9292
stopListener();
93+
log.log(Level.INFO, "Using max concurrency {0}, in queue: {1}", new Object[]{messageListener.getMaxConcurrency(), queueName});
94+
if (useDLQRetries) {
95+
log.log(Level.INFO, "ATTENTION! Using DLQ Strategy for retries with {0} + 1 Max Retries configured!", new Object[]{maxRetries});
96+
} else {
97+
log.log(Level.INFO, "ATTENTION! Using infinite fast retries as Retry Strategy");
98+
}
9399
var baseSubscriber = new LoggerSubscriber<>(getClass().getName());
94100
listenerSubscription = baseSubscriber;
95101
Flux.defer(this::buildConsumeFlux)

0 commit comments

Comments
 (0)