X-Git-Url: https://git.opendaylight.org/gerrit/gitweb?a=blobdiff_plain;f=replicate%2Fmdsal-replicate-netty%2Fsrc%2Fmain%2Fjava%2Forg%2Fopendaylight%2Fmdsal%2Freplicate%2Fnetty%2FSinkRequestHandler.java;h=24904eaaa982bd70138c82202b79e377ff3e0f1c;hb=b94fbc60c0b41da2f6645ab51188fbcdfa74e4af;hp=0b65bc16eeeb9a10ac18256eb2df7cbaa9e60707;hpb=74b2b6e76db17a3602f0e7b90331e1b7cc971ec1;p=mdsal.git

diff --git a/replicate/mdsal-replicate-netty/src/main/java/org/opendaylight/mdsal/replicate/netty/SinkRequestHandler.java b/replicate/mdsal-replicate-netty/src/main/java/org/opendaylight/mdsal/replicate/netty/SinkRequestHandler.java
index 0b65bc16ee..24904eaaa9 100644
--- a/replicate/mdsal-replicate-netty/src/main/java/org/opendaylight/mdsal/replicate/netty/SinkRequestHandler.java
+++ b/replicate/mdsal-replicate-netty/src/main/java/org/opendaylight/mdsal/replicate/netty/SinkRequestHandler.java
@@ -70,6 +70,10 @@ final class SinkRequestHandler extends SimpleChannelInboundHandler<ByteBuf> {
             case Constants.MSG_DTC_APPLY:
                 handleDtcApply();
                 break;
+            case Constants.MSG_PING:
+                LOG.trace("Received PING from Source, sending PONG");
+                ctx.channel().writeAndFlush(Constants.PONG);
+                break;
             default:
                 throw new IllegalStateException("Unexpected message type " + msgType);
         }