The following two encoder classes are taking the role to transform
messages.
public class PDUWrapEncoder<T> implements MessageEncoder<T> {
public void encode(IoSession session, T message,
ProtocolEncoderOutput out)
throws Exception {
PDU pdu = (PDU) message;
out.write(IoBuffer.wrap(pdu.getData().getBuffer()));
}
}
public class ForwardMsgEncoder<T> implements MessageEncoder<T> {
public void encode(IoSession session, T message,
ProtocolEncoderOutput out)
throws Exception {
}
}
I already debugged the application under light workload, it seems ok.
But as long as I apply more than one thousand messages to the
application, it always throws the exception of dataLength.
I think maybe some mistaken inside my source code. Is there anybody can
help to figure it out?
BR
anderson
