@Override
protected void init() {
- serializer = getRegistry().getSerializer(new MessageTypeKey<>(EncodeConstants.OF13_VERSION_ID,
+ serializer = getRegistry().getSerializer(new MessageTypeKey<>(EncodeConstants.OF_VERSION_1_3,
MultipartRequestQueueStats.class));
}
assertEquals(out.readUnsignedInt(), QUEUE_ID.longValue());
assertEquals(out.readableBytes(), 0);
}
-
}
\ No newline at end of file