File tree Expand file tree Collapse file tree 3 files changed +8
-3
lines changed
main/java/com/rabbitmq/client/amqp/impl Expand file tree Collapse file tree 3 files changed +8
-3
lines changed Original file line number Diff line number Diff line change @@ -475,7 +475,7 @@ public <T> T maybeRetry(Supplier<T> task) {
475475 }
476476 },
477477 connectionName ))
478- .description ("Trying to create native connection for '%s'." , connectionName )
478+ .description ("Trying to recover native connection for '%s'." , connectionName )
479479 .delayPolicy (recoveryConfiguration .backOffDelayPolicy ())
480480 .retry (RECOVERY_PREDICATE )
481481 .scheduler (this .scheduledExecutorService ())
Original file line number Diff line number Diff line change @@ -56,11 +56,16 @@ private AsyncRetry(
5656 return ;
5757 }
5858 try {
59+ LOGGER .debug ("Running task '{}'" , description );
5960 V result = task .call ();
6061 LOGGER .debug ("Task '{}' succeeded, completing future" , description );
6162 completableFuture .complete (result );
6263 } catch (Exception e ) {
6364 int attemptCount = attempts .getAndIncrement ();
65+ LOGGER .debug (
66+ "Attempt {} for task '{}' failed, checking retry policy" ,
67+ attemptCount ,
68+ description );
6469 if (retry .test (e )) {
6570 if (delayPolicy .delay (attemptCount ).equals (BackOffDelayPolicy .TIMEOUT )) {
6671 LOGGER .debug (
Original file line number Diff line number Diff line change 1111 <logger name =" org.apache.qpid" level =" error" />
1212 <logger name =" com.rabbitmq.client.amqp.perf" level =" info" />
1313 <logger name =" com.rabbitmq.client.amqp.impl.ConnectionUtils" level =" warn" />
14- <logger name =" com.rabbitmq.client.amqp.impl.AmqpConnection" level =" warn " />
14+ <logger name =" com.rabbitmq.client.amqp.impl.AmqpConnection" level =" debug " />
1515 <logger name =" com.rabbitmq.client.amqp.impl.RecoveryClusterTest" level =" info" />
1616 <logger name =" com.rabbitmq.client.amqp.impl.RecordingTopologyListener" level =" warn" />
1717 <logger name =" com.rabbitmq.client.amqp.impl.ConnectionUtils" level =" warn" />
18- <logger name =" com.rabbitmq.client.amqp.impl.AsyncRetry" level =" warn " />
18+ <logger name =" com.rabbitmq.client.amqp.impl.AsyncRetry" level =" debug " />
1919 <logger name =" com.rabbitmq.client.amqp.impl.EntityRecovery" level =" warn" />
2020 <logger name =" com.rabbitmq.client.amqp.impl.EventLoop" level =" warn" />
2121 <logger name =" com.rabbitmq.client.amqp.impl.AmqpManagement" level =" info" />
You can’t perform that action at this time.
0 commit comments