diff --git a/src/main/java/com/github/shyiko/mysql/binlog/BinaryLogClient.java b/src/main/java/com/github/shyiko/mysql/binlog/BinaryLogClient.java
index d9e7b46..4e78c47 100644
--- a/src/main/java/com/github/shyiko/mysql/binlog/BinaryLogClient.java
+++ b/src/main/java/com/github/shyiko/mysql/binlog/BinaryLogClient.java
@@ -928,6 +928,7 @@ private void confirmSupportOfChecksum(final PacketChannel channel, ChecksumType
     private void listenForEventPackets(final PacketChannel channel) throws IOException {
         ByteArrayInputStream inputStream = channel.getInputStream();
         boolean completeShutdown = false;
+        abortRequest = false;
         try {
             while (!abortRequest && inputStream.peek() != -1) {
                 int packetLength = inputStream.readInteger(3);