Skip to content

Commit cf3cb29

Browse files
committed
Fixed broken "non blocking" mode backport from master
1 parent 810e251 commit cf3cb29

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

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

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -621,7 +621,7 @@ private void listenForEventPackets() throws IOException {
621621
throw new ServerException(errorPacket.getErrorMessage(), errorPacket.getErrorCode(),
622622
errorPacket.getSqlState());
623623
}
624-
if (marker == (byte) 0xFE && !blocking) {
624+
if (marker == 0xFE && !blocking) {
625625
completeShutdown = true;
626626
break;
627627
}

0 commit comments

Comments
 (0)