From 7dff1595e66f89b2428a6c63fb1f4d3655dfd598 Mon Sep 17 00:00:00 2001
From: Connie <conniey@microsoft.com>
Date: Tue, 7 Jan 2020 11:21:46 -0800
Subject: [PATCH] Fixing checkstyle issues.

---
 .../implementation/EventHubConnectionProcessor.java       | 2 +-
 .../EventHubProducerAsyncClientIntegrationTest.java       | 8 ++++----
 2 files changed, 5 insertions(+), 5 deletions(-)

diff --git a/sdk/eventhubs/azure-messaging-eventhubs/src/main/java/com/azure/messaging/eventhubs/implementation/EventHubConnectionProcessor.java b/sdk/eventhubs/azure-messaging-eventhubs/src/main/java/com/azure/messaging/eventhubs/implementation/EventHubConnectionProcessor.java
index 374017d6cbea..e7e206bd1479 100644
--- a/sdk/eventhubs/azure-messaging-eventhubs/src/main/java/com/azure/messaging/eventhubs/implementation/EventHubConnectionProcessor.java
+++ b/sdk/eventhubs/azure-messaging-eventhubs/src/main/java/com/azure/messaging/eventhubs/implementation/EventHubConnectionProcessor.java
@@ -265,7 +265,7 @@ private void requestUpstream() {
     /**
      * Represents a subscriber, waiting for an AMQP connection.
      */
-    private static class ConnectionSubscriber
+    private static final class ConnectionSubscriber
         extends Operators.MonoSubscriber<EventHubAmqpConnection, EventHubAmqpConnection> {
         private final EventHubConnectionProcessor processor;
 
diff --git a/sdk/eventhubs/azure-messaging-eventhubs/src/test/java/com/azure/messaging/eventhubs/EventHubProducerAsyncClientIntegrationTest.java b/sdk/eventhubs/azure-messaging-eventhubs/src/test/java/com/azure/messaging/eventhubs/EventHubProducerAsyncClientIntegrationTest.java
index 9fb235431a24..39514947940e 100644
--- a/sdk/eventhubs/azure-messaging-eventhubs/src/test/java/com/azure/messaging/eventhubs/EventHubProducerAsyncClientIntegrationTest.java
+++ b/sdk/eventhubs/azure-messaging-eventhubs/src/test/java/com/azure/messaging/eventhubs/EventHubProducerAsyncClientIntegrationTest.java
@@ -224,10 +224,10 @@ void worksAfterReconnection() throws InterruptedException {
             .subscribe(instant -> {
                 System.out.println("Sent batch at: " + instant);
             }, error -> {
-                logger.error("Error sending batch: ", error);
-            }, () -> {
-                logger.info("Complete.");
-            });
+                    logger.error("Error sending batch: ", error);
+                }, () -> {
+                    logger.info("Complete.");
+                });
 
         System.out.println("Sleeping while performing work.");
         TimeUnit.MINUTES.sleep(30);