diff --git a/src/main/java/com/corundumstudio/socketio/protocol/PacketDecoder.java b/src/main/java/com/corundumstudio/socketio/protocol/PacketDecoder.java
index 2fa8df34..097f10ca 100644
--- a/src/main/java/com/corundumstudio/socketio/protocol/PacketDecoder.java
+++ b/src/main/java/com/corundumstudio/socketio/protocol/PacketDecoder.java
@@ -301,6 +301,8 @@ private void parseBody(ClientHead head, ByteBuf frame, Packet packet) throws IOE
                     ByteBufInputStream in = new ByteBufInputStream(frame);
                     AckArgs args = jsonSupport.readAckArgs(in, callback);
                     packet.setData(args.getArgs());
+                }else {
+                    frame.clear();
                 }
             }