File tree Expand file tree Collapse file tree 3 files changed +3
-3
lines changed
src/main/java/com/rabbitmq/client/amqp Expand file tree Collapse file tree 3 files changed +3
-3
lines changed Original file line number Diff line number Diff line change @@ -453,7 +453,6 @@ private void recoverAfterConnectionFailure(
453453 recoveryConfiguration ,
454454 this .name (),
455455 amqpException ,
456-
457456 disconnectedHandlerReference );
458457 }
459458 });
Original file line number Diff line number Diff line change @@ -54,7 +54,8 @@ class AmqpEnvironment implements Environment {
5454 private final ConnectionUtils .AffinityCache affinityCache = new ConnectionUtils .AffinityCache ();
5555 private final EventLoop recoveryEventLoop ;
5656 private final ExecutorService recoveryEventLoopExecutorService ;
57- private final CredentialsManagerFactory credentialsManagerFactory = new CredentialsManagerFactory (this );
57+ private final CredentialsManagerFactory credentialsManagerFactory =
58+ new CredentialsManagerFactory (this );
5859
5960 AmqpEnvironment (
6061 ExecutorService executorService ,
Original file line number Diff line number Diff line change 3939
4040public final class TokenCredentialsManager implements CredentialsManager {
4141
42- public static Function <Instant , Duration > DEFAULT_REFRESH_DELAY_STRATEGY =
42+ public static final Function <Instant , Duration > DEFAULT_REFRESH_DELAY_STRATEGY =
4343 ratioRefreshDelayStrategy (0.8f );
4444 private static final Logger LOGGER = LoggerFactory .getLogger (TokenCredentialsManager .class );
4545
You can’t perform that action at this time.
0 commit comments