Fixing checkstyle issues.

Azure · Jan 7, 2020 · 7dff159 · 7dff159
1 parent cd404de
commit 7dff159
Show file tree

Hide file tree

Showing 2 changed files with 5 additions and 5 deletions.
diff --git a/...c/main/java/com/azure/messaging/eventhubs/implementation/EventHubConnectionProcessor.java b/...c/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/...c/test/java/com/azure/messaging/eventhubs/EventHubProducerAsyncClientIntegrationTest.java b/...c/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);