|
@@ -94,6 +94,6 @@ public class DirectLogFetcherTest {
|
|
|
HeaderPacket binlogDumpHeader = new HeaderPacket();
|
|
|
binlogDumpHeader.setPacketBodyLength(cmdBody.length);
|
|
|
binlogDumpHeader.setPacketSequenceNumber((byte) 0x00);
|
|
|
- PacketManager.write(connector.getChannel(), binlogDumpHeader.toBytes(),cmdBody);
|
|
|
+ PacketManager.writePkg(connector.getChannel(), binlogDumpHeader.toBytes(), cmdBody);
|
|
|
}
|
|
|
}
|