pcep/impl/src/main/java/org/opendaylight/protocol/pcep/impl/SimpleMessageHandlerFactory.java

   1 /*
   2  * Copyright (c) 2013 Cisco Systems, Inc. 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.protocol.pcep.impl;
   9
  10 import org.opendaylight.protocol.concepts.HandlerRegistry;
  11 import org.opendaylight.protocol.pcep.spi.MessageHandlerRegistry;
  12 import org.opendaylight.protocol.pcep.spi.MessageParser;
  13 import org.opendaylight.protocol.pcep.spi.MessageSerializer;
  14 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.Message;
  15 import org.opendaylight.yangtools.yang.binding.DataContainer;
  16
  17 import com.google.common.base.Preconditions;
  18
  19 /**
  20  *
  21  */
  22 public final class SimpleMessageHandlerFactory implements MessageHandlerRegistry {
  23         public static final MessageHandlerRegistry INSTANCE;
  24
  25         static {
  26                 final MessageHandlerRegistry reg = new SimpleMessageHandlerFactory();
  27
  28                 // FIXME: fill this in
  29                 // reg.registerMessageHandler(PCEPOpenMessage.class, 1, new PCEPOpenMessageParser());
  30                 // reg.registerMessageHandler(PCEPNotificationMessage.class, 5, new PCEPNotificationMessageParser());
  31                 // reg.registerMessageHandler(PCEPKeepAliveMessage.class, 2, new PCEPKeepAliveMessageParser());
  32                 // reg.registerMessageHandler(PCEPReplyMessage.class, 4, new PCEPReplyMessageParser());
  33                 // reg.registerMessageHandler(PCEPRequestMessage.class, 3, new PCEPRequestMessageParser());
  34                 // reg.registerMessageHandler(PCEPErrorMessage.class, 6, new PCEPErrorMessageParser());
  35                 // reg.registerMessageHandler(PCEPCloseMessage.class, 7, new PCEPCloseMessageParser());
  36                 // reg.registerMessageHandler(PCEPUpdateRequestMessage.class, 11, new PCEPUpdateRequestMessageParser());
  37                 // reg.registerMessageHandler(PCEPReportMessage.class, 10, new PCEPReportMessageParser());
  38                 // reg.registerMessageHandler(PCCreateMessage.class, 12, new PCCreateMessageParser());
  39
  40                 INSTANCE = reg;
  41         }
  42
  43         private final HandlerRegistry<DataContainer, MessageParser, MessageSerializer> handlers = new HandlerRegistry<>();
  44
  45         @Override
  46         public AutoCloseable registerMessageParser(final int messageType, final MessageParser parser) {
  47                 Preconditions.checkArgument(messageType >= 0 && messageType <= 255);
  48                 return handlers.registerParser(messageType, parser);
  49         }
  50
  51         @Override
  52         public AutoCloseable registerMessageSerializer(final Class<? extends Message> msgClass, final MessageSerializer serializer) {
  53                 return handlers.registerSerializer(msgClass, serializer);
  54         }
  55
  56         @Override
  57         public MessageParser getMessageParser(final int messageType) {
  58                 Preconditions.checkArgument(messageType >= 0 && messageType <= 255);
  59                 return handlers.getParser(messageType);
  60         }
  61
  62         @Override
  63         public MessageSerializer getMessageSerializer(final Message message) {
  64                 return handlers.getSerializer(message.getImplementedInterface());
  65         }
  66 }