diff --git a/src/main/java/com/corundumstudio/socketio/protocol/PacketDecoder.java b/src/main/java/com/corundumstudio/socketio/protocol/PacketDecoder.java index 4473bff..c3e838c 100644 --- a/src/main/java/com/corundumstudio/socketio/protocol/PacketDecoder.java +++ b/src/main/java/com/corundumstudio/socketio/protocol/PacketDecoder.java @@ -292,6 +292,10 @@ public class PacketDecoder { head.setLastBinaryPacket(packet); } + if (packet.hasAttachments() && !packet.isAttachmentsLoaded()) { + return; + } + if (packet.getSubType() == PacketType.ACK || packet.getSubType() == PacketType.BINARY_ACK) { ByteBufInputStream in = new ByteBufInputStream(frame);