BUG-7222: Fix clustering BGPPeer NPE

[bgpcep.git] / bgp / rib-impl / src / main / java / org / opendaylight / protocol / bgp / rib / impl / BGPMessageToByteEncoder.java

diff --git a/bgp/rib-impl/src/main/java/org/opendaylight/protocol/bgp/rib/impl/BGPMessageToByteEncoder.java b/bgp/rib-impl/src/main/java/org/opendaylight/protocol/bgp/rib/impl/BGPMessageToByteEncoder.java
index 330ad5f68103b2eb9711c303de22d9904bfcc7ce..7d576920e5c8bfcfd0aa6e101e75fdeb3d36d2ef 100644 (file)
--- a/bgp/rib-impl/src/main/java/org/opendaylight/protocol/bgp/rib/impl/BGPMessageToByteEncoder.java
+++ b/bgp/rib-impl/src/main/java/org/opendaylight/protocol/bgp/rib/impl/BGPMessageToByteEncoder.java
@@ -7,37 +7,36 @@
  */
 package org.opendaylight.protocol.bgp.rib.impl;
 
+import com.google.common.base.Preconditions;
 import io.netty.buffer.ByteBuf;
+import io.netty.buffer.ByteBufUtil;
 import io.netty.channel.ChannelHandler.Sharable;
 import io.netty.channel.ChannelHandlerContext;
 import io.netty.handler.codec.MessageToByteEncoder;
-
 import org.opendaylight.protocol.bgp.parser.spi.MessageRegistry;
-import org.opendaylight.protocol.util.ByteArray;
 import org.opendaylight.yangtools.yang.binding.Notification;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 
-import com.google.common.base.Preconditions;
-
 /**
  *
  */
 @Sharable
 final class BGPMessageToByteEncoder extends MessageToByteEncoder<Notification> {
-       private static final Logger LOG = LoggerFactory.getLogger(BGPMessageToByteEncoder.class);
-       private final MessageRegistry registry;
+    private static final Logger LOG = LoggerFactory.getLogger(BGPMessageToByteEncoder.class);
+    private final MessageRegistry registry;
 
-       BGPMessageToByteEncoder(final MessageRegistry registry) {
-               this.registry = Preconditions.checkNotNull(registry);
-       }
+    BGPMessageToByteEncoder(final MessageRegistry registry) {
+        this.registry = Preconditions.checkNotNull(registry);
+    }
 
-       @Override
-       protected void encode(final ChannelHandlerContext ctx, final Notification msg, final ByteBuf out) throws Exception {
-               LOG.trace("Encoding message: {}", msg);
-               final byte[] bytes = this.registry.serializeMessage(msg);
-               LOG.trace("Encoded message: {}", ByteArray.bytesToHexString(bytes));
-               out.writeBytes(bytes);
-               LOG.debug("Message sent to output: {}", msg);
-       }
+    @Override
+    protected void encode(final ChannelHandlerContext ctx, final Notification msg, final ByteBuf out) {
+        LOG.trace("Encoding message: {}", msg);
+        this.registry.serializeMessage(msg, out);
+        if (LOG.isTraceEnabled()) {
+            LOG.trace("Encoded message: {}", ByteBufUtil.hexDump(out));
+        }
+        LOG.debug("Message sent to output: {}", msg);
+    }
 }