Fixing one build error.

Author: yvgopal

sdk/servicebus/azure-messaging-servicebus/src/main/java/com/azure/messaging/servicebus/ServiceBusSessionManager.java

@@ -325,8 +325,8 @@ Mono<ServiceBusReceiveLink> getActiveLink() {
      * @return A Mono that completes with an unnamed session receiver.
      */
     private Flux<ServiceBusMessageContext> getSession(Scheduler scheduler, boolean disposeOnIdle) {
-        return getActiveLink().flatMap(
-            link -> link.getSessionId().map(sessionId -> sessionReceivers.compute(sessionId.toLowerCase(Locale.ROOT), (key, existing) -> {
+        return getActiveLink().flatMap(link -> link.getSessionId()
+            .map(sessionId -> sessionReceivers.compute(sessionId.toLowerCase(Locale.ROOT), (key, existing) -> {
                 if (existing != null) {
                     return existing;
                 }

sdk/servicebus/azure-messaging-servicebus/src/test/java/com/azure/messaging/servicebus/ServiceBusSingleSessionManagerTest.java

@@ -17,7 +17,6 @@
 import reactor.test.StepVerifier;
 
 import static org.junit.jupiter.api.Assertions.assertEquals;
-import static org.junit.jupiter.api.Assertions.assertNotNull;
 import static org.junit.jupiter.api.Assertions.assertNull;
 import static org.junit.jupiter.api.Assertions.assertTrue;
 import static org.mockito.ArgumentMatchers.any;
@@ -87,9 +86,8 @@ void updateDispositionShouldMatchSessionIdCaseInsensitively() {
 
         // Completely different session ID — disposition should error.
         StepVerifier
-            .create(
-                manager.updateDisposition(lockToken, "other-session", DispositionStatus.COMPLETED, null, null, null,
-                    null))
+            .create(manager.updateDisposition(lockToken, "other-session", DispositionStatus.COMPLETED, null, null, null,
+                null))
             .verifyError();
     }
 

sdk/servicebus/azure-messaging-servicebus/src/test/java/com/azure/messaging/servicebus/SessionsMessagePumpIsolatedTest.java

@@ -464,8 +464,7 @@ public void shouldCompleteMessageWhenSessionIdDiffersInCase() {
         final String acceptedSessionId = "Session-ABC";
         final String messageSessionId = "session-abc";
 
-        final HashMap<Message, ServiceBusReceivedMessage> session1Messages
-            = createMockMessages(messageSessionId, 1);
+        final HashMap<Message, ServiceBusReceivedMessage> session1Messages = createMockMessages(messageSessionId, 1);
         final TestPublisher<AmqpEndpointState> session1EpStates = TestPublisher.createCold();
         session1EpStates.next(AmqpEndpointState.ACTIVE);
         final Session session1 = createMockSession(acceptedSessionId, session1Messages, session1EpStates);