X-Git-Url: https://git.opendaylight.org/gerrit/gitweb?a=blobdiff_plain;f=pcep%2Fspi%2Fsrc%2Fmain%2Fjava%2Forg%2Fopendaylight%2Fprotocol%2Fpcep%2Fspi%2Fpojo%2FSimpleMessageRegistry.java;h=6c87541e6f3177f2e29a245a302a8a175a581222;hb=2bf7a2817fc4954542c374b78e172716fa1317ac;hp=90ab4ab941d3ee4fd050f11cfcce1525e98626bc;hpb=e8b95e767d8fc1ce6b07efde26036153125c1901;p=bgpcep.git diff --git a/pcep/spi/src/main/java/org/opendaylight/protocol/pcep/spi/pojo/SimpleMessageRegistry.java b/pcep/spi/src/main/java/org/opendaylight/protocol/pcep/spi/pojo/SimpleMessageRegistry.java index 90ab4ab941..6c87541e6f 100644 --- a/pcep/spi/src/main/java/org/opendaylight/protocol/pcep/spi/pojo/SimpleMessageRegistry.java +++ b/pcep/spi/src/main/java/org/opendaylight/protocol/pcep/spi/pojo/SimpleMessageRegistry.java @@ -7,6 +7,8 @@ */ package org.opendaylight.protocol.pcep.spi.pojo; +import com.google.common.base.Preconditions; + import io.netty.buffer.ByteBuf; import java.util.List; @@ -22,41 +24,39 @@ import org.opendaylight.yangtools.yang.binding.DataContainer; import org.slf4j.Logger; import org.slf4j.LoggerFactory; -import com.google.common.base.Preconditions; - public final class SimpleMessageRegistry implements MessageRegistry { - private static final Logger LOG = LoggerFactory.getLogger(SimpleMessageRegistry.class); - - private final HandlerRegistry handlers = new HandlerRegistry<>(); - - public AutoCloseable registerMessageParser(final int messageType, final MessageParser parser) { - Preconditions.checkArgument(messageType >= 0 && messageType <= Values.UNSIGNED_BYTE_MAX_VALUE); - return this.handlers.registerParser(messageType, parser); - } - - public AutoCloseable registerMessageSerializer(final Class msgClass, final MessageSerializer serializer) { - return this.handlers.registerSerializer(msgClass, serializer); - } - - @Override - public Message parseMessage(final int messageType, final ByteBuf buffer, final List errors) throws PCEPDeserializerException { - Preconditions.checkArgument(messageType >= 0 && messageType <= Values.UNSIGNED_BYTE_MAX_VALUE); - final MessageParser parser = this.handlers.getParser(messageType); - if (parser == null) { - LOG.warn("PCEP parser for message type {} is not registered.", messageType); - return null; - } - return parser.parseMessage(buffer, errors); - } - - @Override - public void serializeMessage(Message message, ByteBuf buffer) { - final MessageSerializer serializer = this.handlers.getSerializer(message.getImplementedInterface()); - if (serializer == null) { - LOG.warn("PCEP serializer for message type {} is not registered.", message.getClass()); - return; - } - serializer.serializeMessage(message, buffer); - } + private static final Logger LOG = LoggerFactory.getLogger(SimpleMessageRegistry.class); + + private final HandlerRegistry handlers = new HandlerRegistry<>(); + + public AutoCloseable registerMessageParser(final int messageType, final MessageParser parser) { + Preconditions.checkArgument(messageType >= 0 && messageType <= Values.UNSIGNED_BYTE_MAX_VALUE); + return this.handlers.registerParser(messageType, parser); + } + + public AutoCloseable registerMessageSerializer(final Class msgClass, final MessageSerializer serializer) { + return this.handlers.registerSerializer(msgClass, serializer); + } + + @Override + public Message parseMessage(final int messageType, final ByteBuf buffer, final List errors) throws PCEPDeserializerException { + Preconditions.checkArgument(messageType >= 0 && messageType <= Values.UNSIGNED_BYTE_MAX_VALUE); + final MessageParser parser = this.handlers.getParser(messageType); + if (parser == null) { + LOG.warn("PCEP parser for message type {} is not registered.", messageType); + return null; + } + return parser.parseMessage(buffer, errors); + } + + @Override + public void serializeMessage(Message message, ByteBuf buffer) { + final MessageSerializer serializer = this.handlers.getSerializer(message.getImplementedInterface()); + if (serializer == null) { + LOG.warn("PCEP serializer for message type {} is not registered.", message.getClass()); + return; + } + serializer.serializeMessage(message, buffer); + } }