- public ExperimenterMessage bufferToMessage(ByteBuf rawMessage, short version) {
- ExperimenterMessageBuilder builder = new ExperimenterMessageBuilder();
- builder.setVersion(version);
- builder.setXid(rawMessage.readUnsignedInt());
- builder.setExperimenter(rawMessage.readUnsignedInt());
- builder.setExpType(rawMessage.readUnsignedInt());
- int remainingBytes = rawMessage.readableBytes();
- if (remainingBytes > 0) {
- builder.setData(rawMessage.readBytes(remainingBytes).array());
- }
- return builder.build();
+ public void injectDeserializerRegistry(DeserializerRegistry deserializerRegistry) {
+ this.deserializerRegistry = deserializerRegistry;