Get rid of JSR305 annotations

[bgpcep.git] / bgp / parser-spi / src / main / java / org / opendaylight / protocol / bgp / parser / spi / pojo / SimpleMessageRegistry.java

diff --git a/bgp/parser-spi/src/main/java/org/opendaylight/protocol/bgp/parser/spi/pojo/SimpleMessageRegistry.java b/bgp/parser-spi/src/main/java/org/opendaylight/protocol/bgp/parser/spi/pojo/SimpleMessageRegistry.java
index 9c6b6cfcf798e480f63ca7f1305a96991bc91750..38499bb73df8f502278647c31c23301a6f10d94d 100644 (file)
--- a/bgp/parser-spi/src/main/java/org/opendaylight/protocol/bgp/parser/spi/pojo/SimpleMessageRegistry.java
+++ b/bgp/parser-spi/src/main/java/org/opendaylight/protocol/bgp/parser/spi/pojo/SimpleMessageRegistry.java
@@ -7,42 +7,46 @@
  */
 package org.opendaylight.protocol.bgp.parser.spi.pojo;
 
+import io.netty.buffer.ByteBuf;
 import org.opendaylight.protocol.bgp.parser.BGPDocumentedException;
 import org.opendaylight.protocol.bgp.parser.spi.AbstractMessageRegistry;
 import org.opendaylight.protocol.bgp.parser.spi.MessageParser;
 import org.opendaylight.protocol.bgp.parser.spi.MessageSerializer;
+import org.opendaylight.protocol.bgp.parser.spi.PeerSpecificParserConstraint;
 import org.opendaylight.protocol.concepts.HandlerRegistry;
+import org.opendaylight.yangtools.concepts.Registration;
 import org.opendaylight.yangtools.yang.binding.DataContainer;
 import org.opendaylight.yangtools.yang.binding.Notification;
 
 final class SimpleMessageRegistry extends AbstractMessageRegistry {
-       private final HandlerRegistry<DataContainer, MessageParser, MessageSerializer> handlers = new HandlerRegistry<>();
 
-       @Override
-       protected Notification parseBody(final int type, final byte[] body, final int messageLength) throws BGPDocumentedException {
-               final MessageParser parser = handlers.getParser(type);
-               if (parser == null) {
-                       return null;
-               }
-
-               return parser.parseMessageBody(body, messageLength);
-       }
-
-       @Override
-       protected byte[] serializeMessageImpl(final Notification message) {
-               final MessageSerializer serializer = handlers.getSerializer(message.getImplementedInterface());
-               if (serializer == null) {
-                       return null;
-               }
-
-               return serializer.serializeMessage(message);
-       }
-
-       AutoCloseable registerMessageParser(final int messageType, final MessageParser parser) {
-               return handlers.registerParser(messageType, parser);
-       }
-
-       AutoCloseable registerMessageSerializer(final Class<? extends Notification> messageClass, final MessageSerializer serializer) {
-               return handlers.registerSerializer(messageClass, serializer);
-       }
+    private final HandlerRegistry<DataContainer, MessageParser, MessageSerializer> handlers = new HandlerRegistry<>();
+
+    @Override
+    protected Notification parseBody(final int type, final ByteBuf body, final int messageLength,
+            final PeerSpecificParserConstraint constraint) throws BGPDocumentedException {
+        final MessageParser parser = this.handlers.getParser(type);
+        if (parser == null) {
+            return null;
+        }
+        return parser.parseMessageBody(body, messageLength, constraint);
+    }
+
+    @Override
+    protected void serializeMessageImpl(final Notification message, final ByteBuf buffer) {
+        final MessageSerializer serializer = this.handlers.getSerializer(message.implementedInterface());
+        if (serializer == null) {
+            return;
+        }
+        serializer.serializeMessage(message, buffer);
+    }
+
+    Registration registerMessageParser(final int messageType, final MessageParser parser) {
+        return this.handlers.registerParser(messageType, parser);
+    }
+
+    Registration registerMessageSerializer(final Class<? extends Notification> messageClass,
+            final MessageSerializer serializer) {
+        return this.handlers.registerSerializer(messageClass, serializer);
+    }
 }