Fix compilation error caused by recent changes in AbstractChannel

This commit is contained in:
Trustin Lee 2012-05-28 05:32:48 -07:00
parent ef4ee49800
commit e00f303e4f

View File

@ -109,13 +109,11 @@ class EmbeddedChannel extends AbstractChannel {
int byteBufLen = byteBuf.readableBytes();
if (byteBufLen > 0) {
productQueue.add(byteBuf.readBytes(byteBufLen));
writeCounter += byteBufLen;
byteBuf.clear();
}
Queue<Object> msgBuf = buf.messageBuffer();
if (!msgBuf.isEmpty()) {
productQueue.addAll(msgBuf);
writeCounter += msgBuf.size();
msgBuf.clear();
}
}