openflow-protocol-impl/src/main/java/org/opendaylight/openflowjava/protocol/impl/serialization/AdditionalMessageFactoryInitializer.java

   1 /*
   2  * Copyright (c) 2015 NetIDE Consortium and others.  All rights reserved.
   3  *
   4  * This program and the accompanying materials are made available under the
   5  * terms of the Eclipse Public License v1.0 which accompanies this distribution,
   6  * and is available at http://www.eclipse.org/legal/epl-v10.html
   7  */
   8 package org.opendaylight.openflowjava.protocol.impl.serialization;
   9
  10 import org.opendaylight.openflowjava.protocol.api.extensibility.SerializerRegistry;
  11 import org.opendaylight.openflowjava.protocol.api.util.EncodeConstants;
  12 import org.opendaylight.openflowjava.protocol.impl.serialization.factories.BarrierReplyMessageFactory;
  13 import org.opendaylight.openflowjava.protocol.impl.serialization.factories.EchoOutputMessageFactory;
  14 import org.opendaylight.openflowjava.protocol.impl.serialization.factories.EchoRequestMessageFactory;
  15 import org.opendaylight.openflowjava.protocol.impl.serialization.factories.ErrorMessageFactory;
  16 import org.opendaylight.openflowjava.protocol.impl.serialization.factories.ExperimenterMessageFactory;
  17 import org.opendaylight.openflowjava.protocol.impl.serialization.factories.FlowRemovedMessageFactory;
  18 import org.opendaylight.openflowjava.protocol.impl.serialization.factories.GetAsyncReplyMessageFactory;
  19 import org.opendaylight.openflowjava.protocol.impl.serialization.factories.GetConfigReplyMessageFactory;
  20 import org.opendaylight.openflowjava.protocol.impl.serialization.factories.GetFeaturesOutputFactory;
  21 import org.opendaylight.openflowjava.protocol.impl.serialization.factories.HelloMessageFactory;
  22 import org.opendaylight.openflowjava.protocol.impl.serialization.factories.MultipartReplyMessageFactory;
  23 import org.opendaylight.openflowjava.protocol.impl.serialization.factories.OF10BarrierReplyMessageFactory;
  24 import org.opendaylight.openflowjava.protocol.impl.serialization.factories.OF10FeaturesReplyMessageFactory;
  25 import org.opendaylight.openflowjava.protocol.impl.serialization.factories.OF10FlowRemovedMessageFactory;
  26 import org.opendaylight.openflowjava.protocol.impl.serialization.factories.OF10PacketInMessageFactory;
  27 import org.opendaylight.openflowjava.protocol.impl.serialization.factories.OF10PortStatusMessageFactory;
  28 import org.opendaylight.openflowjava.protocol.impl.serialization.factories.OF10QueueGetConfigReplyMessageFactory;
  29 import org.opendaylight.openflowjava.protocol.impl.serialization.factories.OF10StatsReplyMessageFactory;
  30 import org.opendaylight.openflowjava.protocol.impl.serialization.factories.PacketInMessageFactory;
  31 import org.opendaylight.openflowjava.protocol.impl.serialization.factories.PacketOutInputMessageFactory;
  32 import org.opendaylight.openflowjava.protocol.impl.serialization.factories.PortStatusMessageFactory;
  33 import org.opendaylight.openflowjava.protocol.impl.serialization.factories.QueueGetConfigReplyMessageFactory;
  34 import org.opendaylight.openflowjava.protocol.impl.serialization.factories.RoleReplyMessageFactory;
  35 import org.opendaylight.openflowjava.protocol.impl.util.CommonMessageRegistryHelper;
  36 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.BarrierOutput;
  37 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.EchoOutput;
  38 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.EchoRequestMessage;
  39 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.ErrorMessage;
  40 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.ExperimenterMessage;
  41 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.FlowRemovedMessage;
  42 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.GetAsyncOutput;
  43 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.GetConfigOutput;
  44 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.GetFeaturesOutput;
  45 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.GetQueueConfigOutput;
  46 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.HelloMessage;
  47 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.MultipartReplyMessage;
  48 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.PacketInMessage;
  49 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.PacketOutInput;
  50 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.PortStatusMessage;
  51 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.RoleRequestOutput;
  52
  53 /**
  54  * @author giuseppex.petralia@intel.com
  55  *
  56  */
  57 public class AdditionalMessageFactoryInitializer {
  58     private AdditionalMessageFactoryInitializer() {
  59         throw new UnsupportedOperationException("Utility class shouldn't be instantiated");
  60     }
  61
  62     /**
  63      * Registers message serializers implemented within NetIde project into
  64      * provided registry
  65      *
  66      * @param serializerRegistry
  67      *            registry to be initialized with message serializers
  68      */
  69     public static void registerMessageSerializers(SerializerRegistry serializerRegistry) {
  70         // register OF v1.0 message serializers
  71         short version = EncodeConstants.OF10_VERSION_ID;
  72         CommonMessageRegistryHelper registryHelper = new CommonMessageRegistryHelper(version, serializerRegistry);
  73         registryHelper.registerSerializer(ErrorMessage.class, new ErrorMessageFactory());
  74         registryHelper.registerSerializer(EchoRequestMessage.class, new EchoRequestMessageFactory());
  75         registryHelper.registerSerializer(EchoOutput.class, new EchoOutputMessageFactory());
  76         registryHelper.registerSerializer(GetFeaturesOutput.class, new OF10FeaturesReplyMessageFactory());
  77         registryHelper.registerSerializer(GetConfigOutput.class, new GetConfigReplyMessageFactory());
  78         registryHelper.registerSerializer(PacketInMessage.class, new OF10PacketInMessageFactory());
  79         registryHelper.registerSerializer(FlowRemovedMessage.class, new OF10FlowRemovedMessageFactory());
  80         registryHelper.registerSerializer(PortStatusMessage.class, new OF10PortStatusMessageFactory());
  81         registryHelper.registerSerializer(MultipartReplyMessage.class, new OF10StatsReplyMessageFactory());
  82         registryHelper.registerSerializer(BarrierOutput.class, new OF10BarrierReplyMessageFactory());
  83         registryHelper.registerSerializer(GetQueueConfigOutput.class, new OF10QueueGetConfigReplyMessageFactory());
  84
  85         // register OF v1.3 message serializers
  86         version = EncodeConstants.OF13_VERSION_ID;
  87         registryHelper = new CommonMessageRegistryHelper(version, serializerRegistry);
  88         registryHelper.registerSerializer(EchoOutput.class, new EchoOutputMessageFactory());
  89         registryHelper.registerSerializer(PacketInMessage.class, new PacketInMessageFactory());
  90         registryHelper.registerSerializer(PacketOutInput.class, new PacketOutInputMessageFactory());
  91         registryHelper.registerSerializer(GetFeaturesOutput.class, new GetFeaturesOutputFactory());
  92         registryHelper.registerSerializer(EchoRequestMessage.class, new EchoRequestMessageFactory());
  93         registryHelper.registerSerializer(MultipartReplyMessage.class, new MultipartReplyMessageFactory());
  94         registryHelper.registerSerializer(HelloMessage.class, new HelloMessageFactory());
  95         registryHelper.registerSerializer(ErrorMessage.class, new ErrorMessageFactory());
  96         registryHelper.registerSerializer(ExperimenterMessage.class, new ExperimenterMessageFactory());
  97         registryHelper.registerSerializer(GetConfigOutput.class, new GetConfigReplyMessageFactory());
  98         registryHelper.registerSerializer(FlowRemovedMessage.class, new FlowRemovedMessageFactory());
  99         registryHelper.registerSerializer(PortStatusMessage.class, new PortStatusMessageFactory());
 100         registryHelper.registerSerializer(BarrierOutput.class, new BarrierReplyMessageFactory());
 101         registryHelper.registerSerializer(GetQueueConfigOutput.class, new QueueGetConfigReplyMessageFactory());
 102         registryHelper.registerSerializer(RoleRequestOutput.class, new RoleReplyMessageFactory());
 103         registryHelper.registerSerializer(GetAsyncOutput.class, new GetAsyncReplyMessageFactory());
 104     }
 105 }