apply formatting

Author: Mark Kuhn

src/main/java/software/amazon/cloudwatchlogs/emf/sinks/TCPClient.java

@@ -21,7 +21,6 @@
 import java.net.InetSocketAddress;
 import java.net.Socket;
 import java.util.concurrent.*;
-
 import lombok.extern.slf4j.Slf4j;
 
 /** A client that would connect to a TCP socket. */
@@ -72,10 +71,7 @@ public synchronized void sendMessage(String message) {
         }
     }
 
-    /**
-     * Performs checks to see if the socket is connected.
-     * If not, it will attempt to connect.
-     */
+    /** Performs checks to see if the socket is connected. If not, it will attempt to connect. */
     private void checkConnection() {
         if (socket == null || socket.isClosed() || shouldConnect) {
             connect();

src/test/java/software/amazon/cloudwatchlogs/emf/sinks/TCPClientTest.java

@@ -55,43 +55,50 @@ protected Socket createSocket() {
     public void testSendMessageAfterAgentReconnect() throws InterruptedException {
         String[] messages = new String[2];
 
-        Thread server = new Thread(() -> {
-            try {
-                ServerSocket serverSocket = new ServerSocket(Endpoint.DEFAULT_TCP_ENDPOINT.getPort());
-                Socket socket = serverSocket.accept();
-                InputStream is = socket.getInputStream();
-                byte[] bytes = new byte[1024];
-                int read = is.read(bytes);
-                messages[0] = new String(bytes, 0, read);
-
-                // Disconnect
-                socket.close();
-                serverSocket.close();
-
-                // Reconnect
-                serverSocket = new ServerSocket(Endpoint.DEFAULT_TCP_ENDPOINT.getPort());
-                socket = serverSocket.accept();
-                is = socket.getInputStream();
-                bytes = new byte[1024];
-                read = is.read(bytes);
-                messages[1] = new String(bytes, 0, read);
-
-                socket.close();
-                serverSocket.close();
-            } catch (IOException e) {
-                throw new RuntimeException(e);
-            }
-        });
-
-        Thread client = new Thread(() -> {
-            try (TCPClient tcpClient = new TCPClient(Endpoint.DEFAULT_TCP_ENDPOINT)) {
-                tcpClient.sendMessage("Test message 1");
-                Thread.sleep(1000);
-                tcpClient.sendMessage("Test message 2");
-            } catch (InterruptedException | IOException e) {
-                throw new RuntimeException(e);
-            }
-        });
+        Thread server =
+                new Thread(
+                        () -> {
+                            try {
+                                ServerSocket serverSocket =
+                                        new ServerSocket(Endpoint.DEFAULT_TCP_ENDPOINT.getPort());
+                                Socket socket = serverSocket.accept();
+                                InputStream is = socket.getInputStream();
+                                byte[] bytes = new byte[1024];
+                                int read = is.read(bytes);
+                                messages[0] = new String(bytes, 0, read);
+
+                                // Disconnect
+                                socket.close();
+                                serverSocket.close();
+
+                                // Reconnect
+                                serverSocket =
+                                        new ServerSocket(Endpoint.DEFAULT_TCP_ENDPOINT.getPort());
+                                socket = serverSocket.accept();
+                                is = socket.getInputStream();
+                                bytes = new byte[1024];
+                                read = is.read(bytes);
+                                messages[1] = new String(bytes, 0, read);
+
+                                socket.close();
+                                serverSocket.close();
+                            } catch (IOException e) {
+                                throw new RuntimeException(e);
+                            }
+                        });
+
+        Thread client =
+                new Thread(
+                        () -> {
+                            try (TCPClient tcpClient =
+                                    new TCPClient(Endpoint.DEFAULT_TCP_ENDPOINT)) {
+                                tcpClient.sendMessage("Test message 1");
+                                Thread.sleep(1000);
+                                tcpClient.sendMessage("Test message 2");
+                            } catch (InterruptedException | IOException e) {
+                                throw new RuntimeException(e);
+                            }
+                        });
 
         server.start();
         client.start();