Merge pull request #153 from subdir/patch-1

NPE on mysql disconnect
shyiko · Feb 21, 2017 · ae090b4 · ae090b4
2 parents 6c44bac + 32df79d
commit ae090b4
Showing 1 changed file with 3 additions and 0 deletions.
diff --git a/src/main/java/com/github/shyiko/mysql/binlog/BinaryLogClient.java b/src/main/java/com/github/shyiko/mysql/binlog/BinaryLogClient.java
@@ -741,6 +741,9 @@ private void listenForEventPackets() throws IOException {
                     event = eventDeserializer.nextEvent(packetLength == MAX_PACKET_LENGTH ?
                         new ByteArrayInputStream(readPacketSplitInChunks(inputStream, packetLength - 1)) :
                         inputStream);
+                    if (event == null) {
+                        throw new EOFException();
+                    }
                 } catch (Exception e) {
                     Throwable cause = e instanceof EventDataDeserializationException ? e.getCause() : e;
                     if (cause instanceof EOFException || cause instanceof SocketException) {