PROD VERSION Memory leak on disconnect is fixed

Pavel Chertalev · Pavel Chertalev · commit 58afe49ee40b · 2020-01-10T11:19:04.000+03:00
diff --git a/pom.xml b/pom.xml
@@ -5,7 +5,7 @@
     <groupId>info.bitrich.xchange-stream</groupId>
     <artifactId>xchange-stream-parent</artifactId>
     <packaging>pom</packaging>
-    <version>4.3.17.1-dsx</version>
+    <version>4.3.17.2-dsx</version>
 
     <modules>
         <module>xchange-stream-core</module>
diff --git a/service-core/pom.xml b/service-core/pom.xml
@@ -3,7 +3,7 @@
     <parent>
         <artifactId>xchange-stream-parent</artifactId>
         <groupId>info.bitrich.xchange-stream</groupId>
-        <version>4.3.17.1-dsx</version>
+        <version>4.3.17.2-dsx</version>
     </parent>
     <modelVersion>4.0.0</modelVersion>
 
diff --git a/service-netty/pom.xml b/service-netty/pom.xml
@@ -3,7 +3,7 @@
     <parent>
         <artifactId>xchange-stream-parent</artifactId>
         <groupId>info.bitrich.xchange-stream</groupId>
-        <version>4.3.17.1-dsx</version>
+        <version>4.3.17.2-dsx</version>
     </parent>
     <modelVersion>4.0.0</modelVersion>
 
diff --git a/service-netty/src/main/java/info/bitrich/xchangestream/service/netty/NettyStreamingService.java b/service-netty/src/main/java/info/bitrich/xchangestream/service/netty/NettyStreamingService.java
@@ -251,7 +251,7 @@ public Completable disconnect() {
                 CloseWebSocketFrame closeFrame = new CloseWebSocketFrame();
                 webSocketChannel.writeAndFlush(closeFrame).addListener(future -> {
                     channels.clear();
-                    webSocketChannel.eventLoop().shutdownGracefully(2, 30, TimeUnit.SECONDS).addListener(f -> {
+                    eventLoopGroup.shutdownGracefully(2, 30, TimeUnit.SECONDS).addListener(f -> {
                         LOG.info("Disconnected");
                         completable.onComplete();
                     });
diff --git a/service-pubnub/pom.xml b/service-pubnub/pom.xml
@@ -3,7 +3,7 @@
     <parent>
         <artifactId>xchange-stream-parent</artifactId>
         <groupId>info.bitrich.xchange-stream</groupId>
-        <version>4.3.17.1-dsx</version>
+        <version>4.3.17.2-dsx</version>
     </parent>
     <modelVersion>4.0.0</modelVersion>
 
diff --git a/service-pusher/pom.xml b/service-pusher/pom.xml
@@ -3,7 +3,7 @@
     <parent>
         <artifactId>xchange-stream-parent</artifactId>
         <groupId>info.bitrich.xchange-stream</groupId>
-        <version>4.3.17.1-dsx</version>
+        <version>4.3.17.2-dsx</version>
     </parent>
     <modelVersion>4.0.0</modelVersion>
 
diff --git a/service-wamp/pom.xml b/service-wamp/pom.xml
@@ -3,7 +3,7 @@
     <parent>
         <artifactId>xchange-stream-parent</artifactId>
         <groupId>info.bitrich.xchange-stream</groupId>
-        <version>4.3.17.1-dsx</version>
+        <version>4.3.17.2-dsx</version>
     </parent>
     <modelVersion>4.0.0</modelVersion>
 
diff --git a/xchange-bankera/pom.xml b/xchange-bankera/pom.xml
@@ -3,7 +3,7 @@
     <parent>
         <artifactId>xchange-stream-parent</artifactId>
         <groupId>info.bitrich.xchange-stream</groupId>
-        <version>4.3.17.1-dsx</version>
+        <version>4.3.17.2-dsx</version>
     </parent>
     <modelVersion>4.0.0</modelVersion>
 
diff --git a/xchange-binance/pom.xml b/xchange-binance/pom.xml
@@ -3,7 +3,7 @@
     <parent>
         <artifactId>xchange-stream-parent</artifactId>
         <groupId>info.bitrich.xchange-stream</groupId>
-        <version>4.3.17.1-dsx</version>
+        <version>4.3.17.2-dsx</version>
     </parent>
     <modelVersion>4.0.0</modelVersion>
 
diff --git a/xchange-bitfinex/pom.xml b/xchange-bitfinex/pom.xml
@@ -3,7 +3,7 @@
     <parent>
         <artifactId>xchange-stream-parent</artifactId>
         <groupId>info.bitrich.xchange-stream</groupId>
-        <version>4.3.17.1-dsx</version>
+        <version>4.3.17.2-dsx</version>
     </parent>
     <modelVersion>4.0.0</modelVersion>
 
diff --git a/xchange-bitflyer/pom.xml b/xchange-bitflyer/pom.xml
@@ -3,7 +3,7 @@
     <parent>
         <artifactId>xchange-stream-parent</artifactId>
         <groupId>info.bitrich.xchange-stream</groupId>
-        <version>4.3.17.1-dsx</version>
+        <version>4.3.17.2-dsx</version>
     </parent>
     <modelVersion>4.0.0</modelVersion>
 
diff --git a/xchange-bitmex/pom.xml b/xchange-bitmex/pom.xml
@@ -3,7 +3,7 @@
     <parent>
         <artifactId>xchange-stream-parent</artifactId>
         <groupId>info.bitrich.xchange-stream</groupId>
-        <version>4.3.17.1-dsx</version>
+        <version>4.3.17.2-dsx</version>
     </parent>
     <modelVersion>4.0.0</modelVersion>
 
diff --git a/xchange-bitstamp/pom.xml b/xchange-bitstamp/pom.xml
@@ -3,7 +3,7 @@
     <parent>
         <artifactId>xchange-stream-parent</artifactId>
         <groupId>info.bitrich.xchange-stream</groupId>
-        <version>4.3.17.1-dsx</version>
+        <version>4.3.17.2-dsx</version>
     </parent>
     <modelVersion>4.0.0</modelVersion>
 
diff --git a/xchange-cexio/pom.xml b/xchange-cexio/pom.xml
@@ -3,7 +3,7 @@
     <parent>
         <artifactId>xchange-stream-parent</artifactId>
         <groupId>info.bitrich.xchange-stream</groupId>
-        <version>4.3.17.1-dsx</version>
+        <version>4.3.17.2-dsx</version>
     </parent>
     <modelVersion>4.0.0</modelVersion>
 
diff --git a/xchange-coinbasepro/pom.xml b/xchange-coinbasepro/pom.xml
@@ -3,7 +3,7 @@
     <parent>
         <artifactId>xchange-stream-parent</artifactId>
         <groupId>info.bitrich.xchange-stream</groupId>
-        <version>4.3.17.1-dsx</version>
+        <version>4.3.17.2-dsx</version>
     </parent>
     <modelVersion>4.0.0</modelVersion>
 
diff --git a/xchange-coinmate/pom.xml b/xchange-coinmate/pom.xml
@@ -3,7 +3,7 @@
     <parent>
         <artifactId>xchange-stream-parent</artifactId>
         <groupId>info.bitrich.xchange-stream</groupId>
-        <version>4.3.17.1-dsx</version>
+        <version>4.3.17.2-dsx</version>
     </parent>
     <modelVersion>4.0.0</modelVersion>
 
diff --git a/xchange-gemini/pom.xml b/xchange-gemini/pom.xml
@@ -3,7 +3,7 @@
     <parent>
         <artifactId>xchange-stream-parent</artifactId>
         <groupId>info.bitrich.xchange-stream</groupId>
-        <version>4.3.17.1-dsx</version>
+        <version>4.3.17.2-dsx</version>
     </parent>
     <modelVersion>4.0.0</modelVersion>
 
diff --git a/xchange-hitbtc/pom.xml b/xchange-hitbtc/pom.xml
@@ -3,7 +3,7 @@
     <parent>
         <artifactId>xchange-stream-parent</artifactId>
         <groupId>info.bitrich.xchange-stream</groupId>
-        <version>4.3.17.1-dsx</version>
+        <version>4.3.17.2-dsx</version>
     </parent>
     <modelVersion>4.0.0</modelVersion>
 
diff --git a/xchange-kraken/pom.xml b/xchange-kraken/pom.xml
@@ -5,7 +5,7 @@
     <parent>
         <artifactId>xchange-stream-parent</artifactId>
         <groupId>info.bitrich.xchange-stream</groupId>
-        <version>4.3.17.1-dsx</version>
+        <version>4.3.17.2-dsx</version>
     </parent>
     <modelVersion>4.0.0</modelVersion>
 
diff --git a/xchange-okcoin/pom.xml b/xchange-okcoin/pom.xml
@@ -3,7 +3,7 @@
     <parent>
         <artifactId>xchange-stream-parent</artifactId>
         <groupId>info.bitrich.xchange-stream</groupId>
-        <version>4.3.17.1-dsx</version>
+        <version>4.3.17.2-dsx</version>
     </parent>
     <modelVersion>4.0.0</modelVersion>
 
diff --git a/xchange-poloniex/pom.xml b/xchange-poloniex/pom.xml
@@ -3,7 +3,7 @@
     <parent>
         <artifactId>xchange-stream-parent</artifactId>
         <groupId>info.bitrich.xchange-stream</groupId>
-        <version>4.3.17.1-dsx</version>
+        <version>4.3.17.2-dsx</version>
     </parent>
     <modelVersion>4.0.0</modelVersion>
 
diff --git a/xchange-poloniex2/pom.xml b/xchange-poloniex2/pom.xml
@@ -3,7 +3,7 @@
     <parent>
         <artifactId>xchange-stream-parent</artifactId>
         <groupId>info.bitrich.xchange-stream</groupId>
-        <version>4.3.17.1-dsx</version>
+        <version>4.3.17.2-dsx</version>
     </parent>
     <modelVersion>4.0.0</modelVersion>
 
diff --git a/xchange-stream-core/pom.xml b/xchange-stream-core/pom.xml
@@ -3,7 +3,7 @@
     <parent>
         <artifactId>xchange-stream-parent</artifactId>
         <groupId>info.bitrich.xchange-stream</groupId>
-        <version>4.3.17.1-dsx</version>
+        <version>4.3.17.2-dsx</version>
     </parent>
     <modelVersion>4.0.0</modelVersion>
 
diff --git a/xchange-wex/pom.xml b/xchange-wex/pom.xml
@@ -3,7 +3,7 @@
     <parent>
         <artifactId>xchange-stream-parent</artifactId>
         <groupId>info.bitrich.xchange-stream</groupId>
-        <version>4.3.17.1-dsx</version>
+        <version>4.3.17.2-dsx</version>
     </parent>
     <modelVersion>4.0.0</modelVersion>
 
