short keyLength = currentMessage.getKeyLength();
if (keyLength > 0) {
if (in.readableBytes() < keyLength) {
return;
}
<BUG>currentMessage.setKey(in.toString(in.readerIndex(), keyLength, CharsetUtil.UTF_8));
in.skipBytes(keyLength);
}</BUG>
out.add(currentMessage);
state = State.READ_CONTENT;

short keyLength = currentMessage.getKeyLength();
if (keyLength > 0) {
if (in.readableBytes() < keyLength) {
return;
}
byte[] key = new byte[keyLength];
in.readBytes(key);
currentMessage.setKey(key);
}
out.add(currentMessage);
state = State.READ_CONTENT;
