Bump upstreams for 2022.09 Chlorine

[openflowplugin.git] / openflowjava / openflow-protocol-impl / src / main / java / org / opendaylight / openflowjava / protocol / impl / serialization / SerializationFactory.java

diff --git a/openflowjava/openflow-protocol-impl/src/main/java/org/opendaylight/openflowjava/protocol/impl/serialization/SerializationFactory.java b/openflowjava/openflow-protocol-impl/src/main/java/org/opendaylight/openflowjava/protocol/impl/serialization/SerializationFactory.java
index 6a21b2df69e96a08c4755adf47e2a613a13f73aa..702cd87ea3ccf2ca9ff2c6bdbc6c350f7345f39e 100644 (file)
--- a/openflowjava/openflow-protocol-impl/src/main/java/org/opendaylight/openflowjava/protocol/impl/serialization/SerializationFactory.java
+++ b/openflowjava/openflow-protocol-impl/src/main/java/org/opendaylight/openflowjava/protocol/impl/serialization/SerializationFactory.java
@@ -13,6 +13,7 @@ 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;
+import org.opendaylight.yangtools.yang.common.Uint8;
 
 /**
  * Serializes messages.
@@ -21,8 +22,11 @@ import org.opendaylight.yangtools.yang.binding.DataObject;
  * @author timotej.kubas
  */
 public class SerializationFactory {
+    private final SerializerRegistry registry;
 
-    private SerializerRegistry registry;
+    public SerializationFactory(final SerializerRegistry registry) {
+        this.registry = registry;
+    }
 
     /**
      * Transforms POJO message into ByteBuf.
@@ -31,19 +35,9 @@ public class SerializationFactory {
      * @param out ByteBuf for storing and sending transformed message
      * @param message POJO message
      */
-    public void messageToBuffer(short version, ByteBuf out, DataObject message) {
+    public void messageToBuffer(final Uint8 version, final ByteBuf out, final DataObject message) {
         OFSerializer<DataObject> serializer = registry.getSerializer(
-                new MessageTypeKey<>(version, message.getImplementedInterface()));
+                new MessageTypeKey<>(version, message.implementedInterface()));
         serializer.serialize(message, out);
     }
-
-    /**
-     * Sets the SerializerRegistry.
-     *
-     * @param serializerRegistry registry with serializers
-     */
-    public void setSerializerTable(SerializerRegistry serializerRegistry) {
-        this.registry = serializerRegistry;
-    }
-
 }