Trying to ensure no blocking close on force reconnect from socket write timeout

Author: scottf

src/main/java/io/nats/client/impl/NatsConnection.java

@@ -284,8 +284,6 @@ public void forceReconnect() throws IOException, InterruptedException {
     }
 
     void forceReconnectImpl() throws IOException, InterruptedException {
-        NatsConnectionWriter oldWriter = writer;
-
         closeSocketLock.lock();
         try {
             updateStatus(Status.DISCONNECTED);
@@ -299,8 +297,7 @@ void forceReconnectImpl() throws IOException, InterruptedException {
                 try {
                     dataPort.close();
                 }
-                catch (IOException ignore) {
-                }
+                catch (IOException ignore) {}
                 finally {
                     dataPort = null;
                 }

src/main/java/io/nats/client/impl/SocketDataPortWithWriteTimeout.java

@@ -38,10 +38,6 @@ public void run() {
             if (System.nanoTime() > writeMustBeDoneBy) {
                 writeWatcherTimer.cancel(); // we don't need to repeat this
                 connection.executeCallback((c, el) -> el.socketWriteTimeout(c));
-                try {
-                    out.close();
-                }
-                catch (IOException ignore) {}
                 connection.getExecutor().submit(() -> {
                     try {
                         connection.forceReconnect();