- out.writeByte(message.getVersion());\r
- out.writeByte(MESSAGE_TYPE);\r
- out.writeShort(OFFrameDecoder.LENGTH_OF_HEADER);\r
- out.writeInt(message.getXid().intValue());\r
+ ByteBufUtils.writeOFHeader(instance, message, out);\r
+ byte[] data = message.getData();\r
+ if (data != null) {\r
+ out.writeBytes(data);\r
+ }\r
+ }\r
+\r
+ @Override\r
+ public int computeLength(EchoReplyInput message) {\r
+ int length = MESSAGE_LENGTH;\r
+ byte[] data = message.getData();\r
+ if (data != null) {\r
+ length += data.length;\r
+ }\r
+ return length;\r
+ }\r
+\r
+ @Override\r
+ public byte getMessageType() {\r
+ return MESSAGE_TYPE;\r