import io.netty.buffer.ByteBuf;
-import org.opendaylight.openflowjava.protocol.api.extensibility.MessageTypeKey;
import org.opendaylight.openflowjava.protocol.api.extensibility.OFSerializer;
import org.opendaylight.openflowjava.protocol.api.extensibility.SerializerRegistry;
+import org.opendaylight.openflowjava.protocol.api.keys.MessageTypeKey;
import org.opendaylight.yangtools.yang.binding.DataObject;
/**
public class SerializationFactory {
private SerializerRegistry registry;
-
+
/**
* Transforms POJO message into ByteBuf
* @param version version used for encoding received message
public void messageToBuffer(short version, ByteBuf out, DataObject message) {
OFSerializer<DataObject> serializer = registry.getSerializer(
new MessageTypeKey<>(version, message.getImplementedInterface()));
- if (serializer != null) {
- serializer.serialize(message, out);
- }
+ serializer.serialize(message, out);
}
/**