Enable medieval shutdown

Author: fivetran-mattalexander

src/main/java/com/github/shyiko/mysql/binlog/NewBinaryLogClient.java

@@ -976,10 +976,15 @@ private void listenForEventPackets(final PacketChannel channel) throws IOExcepti
                 }
             }
         } finally {
-            abortRequest = false;
             if (connected) {
-                if (completeShutdown) {
+                if (completeShutdown || abortRequest) {
+                    System.out.println("***********");
+                    System.out.println("MEDIEVAL ABORT ENGAGED");
+                    System.out.println("***********");
                     disconnect(); // initiate complete shutdown sequence (which includes keep alive thread)
+                    System.out.println("***********");
+                    System.out.println("DISCONNECTED");
+                    System.out.println("***********");
                 } else {
                     closeChannel(channel);
                 }
@@ -1174,7 +1179,13 @@ public void disconnect() throws IOException {
 
         terminateKeepAliveThread(keepAliveThreadExecutor);
         closeChannel(channel);
+        System.out.println("**********");
+        System.out.println("WAITING");
+        System.out.println("**********");
         waitForConnectToTerminate(connectLatch);
+        System.out.println("**********");
+        System.out.println("DONE");
+        System.out.println("**********");
     }
 
     @Override