During forceReconnect, ensure reader/writer is stopped before continuing (#1203)

Author: MauriceVanVeen

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

@@ -325,8 +325,16 @@ void forceReconnectImpl(ForceReconnectOptions options) throws InterruptedExcepti
             }
 
             // stop i/o
-            reader.stop(false);
-            writer.stop();
+            try {
+                this.reader.stop(false).get(10, TimeUnit.SECONDS);
+            } catch (Exception ex) {
+                processException(ex);
+            }
+            try {
+                this.writer.stop().get(10, TimeUnit.SECONDS);
+            } catch (Exception ex) {
+                processException(ex);
+            }
 
             // new reader/writer
             reader = new NatsConnectionReader(this);
@@ -704,13 +712,19 @@ void handleCommunicationIssue(Exception io) {
         // Spawn a thread so we don't have timing issues with
         // waiting on read/write threads
         executor.submit(() -> {
-            try {
-                // any issue that brings us here is pretty serious
-                // so we are comfortable forcing the close
-                this.closeSocket(true, true);
-            } catch (InterruptedException e) {
-                processException(e);
-                Thread.currentThread().interrupt();
+            if (!tryingToConnect.get()) {
+                try {
+                    tryingToConnect.set(true);
+
+                    // any issue that brings us here is pretty serious
+                    // so we are comfortable forcing the close
+                    this.closeSocket(true, true);
+                } catch (InterruptedException e) {
+                    processException(e);
+                    Thread.currentThread().interrupt();
+                } finally {
+                    tryingToConnect.set(false);
+                }
             }
         });
     }