Fixed PongFrame leak

Author: artem-v

services-gateway-netty/src/main/java/io/scalecube/services/gateway/GatewayTemplate.java

@@ -1,10 +1,8 @@
 package io.scalecube.services.gateway;
 
-import io.scalecube.services.api.ServiceMessage;
 import java.net.InetSocketAddress;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
-import reactor.core.publisher.Hooks;
 import reactor.core.publisher.Mono;
 import reactor.netty.DisposableServer;
 import reactor.netty.http.server.HttpServer;
@@ -14,14 +12,6 @@ public abstract class GatewayTemplate implements Gateway {
 
   private static final Logger LOGGER = LoggerFactory.getLogger(GatewayTemplate.class);
 
-  static {
-    Hooks.onNextDropped(
-        obj -> {
-          ReferenceCountUtil.safestRelease(
-              obj instanceof ServiceMessage ? ((ServiceMessage) obj).data() : obj);
-        });
-  }
-
   protected final GatewayOptions options;
 
   protected GatewayTemplate(GatewayOptions options) {

services-gateway-tests/src/test/java/io/scalecube/services/gateway/websocket/WebsocketClientConnectionTest.java

@@ -190,6 +190,7 @@ void testKeepalive()
           @Override
           public void channelRead(ChannelHandlerContext ctx, Object msg) throws Exception {
             if (msg instanceof PongWebSocketFrame) {
+              ((PongWebSocketFrame) msg).release();
               keepaliveLatch.countDown();
             } else {
               super.channelRead(ctx, msg);