From a572672ae84ac01910fbc206a835c81eef4a3aeb Mon Sep 17 00:00:00 2001 From: Connie Date: Mon, 6 Jan 2020 18:58:04 -0800 Subject: [PATCH] Fixing indentation. --- .../ActiveClientTokenManager.java | 18 +++++++++--------- 1 file changed, 9 insertions(+), 9 deletions(-) diff --git a/sdk/core/azure-core-amqp/src/main/java/com/azure/core/amqp/implementation/ActiveClientTokenManager.java b/sdk/core/azure-core-amqp/src/main/java/com/azure/core/amqp/implementation/ActiveClientTokenManager.java index e0761ac0e0897..4174c9e1b10f7 100644 --- a/sdk/core/azure-core-amqp/src/main/java/com/azure/core/amqp/implementation/ActiveClientTokenManager.java +++ b/sdk/core/azure-core-amqp/src/main/java/com/azure/core/amqp/implementation/ActiveClientTokenManager.java @@ -104,7 +104,7 @@ public void close() { if (subscription != null) { subscription.dispose(); - } + } } private Disposable scheduleRefreshTokenTask(Duration initialRefresh) { @@ -133,13 +133,13 @@ private Disposable scheduleRefreshTokenTask(Duration initialRefresh) { lastRefreshInterval.set(nextRefresh); durationSourceSink.next(Duration.ofMillis(interval)); }, error -> { - logger.error("Error occurred while refreshing token that is not retriable. Not scheduling" - + " refresh task. Use ActiveClientTokenManager.authorize() to schedule task again.", error); - hasScheduled.set(false); - durationSourceSink.complete(); - authorizationResultsSink.error(error); - }, () -> { - logger.info("Completed refresh token task."); - }); + logger.error("Error occurred while refreshing token that is not retriable. Not scheduling" + + " refresh task. Use ActiveClientTokenManager.authorize() to schedule task again.", error); + hasScheduled.set(false); + durationSourceSink.complete(); + authorizationResultsSink.error(error); + }, () -> { + logger.info("Completed refresh token task."); + }); } }