Fixed #84 - keep alive thread interfering with non-blocking mode

Author: shyiko

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

@@ -610,6 +610,7 @@ private void confirmSupportOfChecksum(ChecksumType checksumType) throws IOExcept
 
     private void listenForEventPackets() throws IOException {
         ByteArrayInputStream inputStream = channel.getInputStream();
+        boolean completeShutdown = false;
         try {
             while (inputStream.peek() != -1) {
                 int packetLength = inputStream.readInteger(3);
@@ -621,6 +622,7 @@ private void listenForEventPackets() throws IOException {
                         errorPacket.getSqlState());
                 }
                 if (marker == (byte) 0xFE && !blocking) {
+                    completeShutdown = true;
                     break;
                 }
                 Event event;
@@ -658,7 +660,11 @@ private void listenForEventPackets() throws IOException {
             }
         } finally {
             if (isConnected()) {
-                disconnectChannel();
+                if (completeShutdown) {
+                    disconnect(); // initiate complete shutdown sequence (which includes keep alive thread)
+                } else {
+                    disconnectChannel();
+                }
             }
         }
     }