From 6ef53a25efedf73c8dc61a6470b5fbfd7c2eb08a Mon Sep 17 00:00:00 2001
From: Andrei Ivanov <Andrei.B.Ivanov@gmail.com>
Date: Mon, 23 Mar 2020 11:35:37 +0300
Subject: [PATCH] Memory leak fixed

---
 pom.xml                                                        | 2 +-
 .../iponweb/disthene/reader/server/ReaderServerHandler.java    | 3 ++-
 2 files changed, 3 insertions(+), 2 deletions(-)

diff --git a/pom.xml b/pom.xml
index 532e248c..13ecb8bc 100644
--- a/pom.xml
+++ b/pom.xml
@@ -4,7 +4,7 @@
     <groupId>net.iponweb.disthene.reader</groupId>
     <artifactId>disthene-reader</artifactId>
     <packaging>jar</packaging>
-    <version>1.0.11</version>
+    <version>1.0.12</version>
     <name>disthene-reader</name>
     <url>http://maven.apache.org</url>
     <dependencies>
diff --git a/src/main/java/net/iponweb/disthene/reader/server/ReaderServerHandler.java b/src/main/java/net/iponweb/disthene/reader/server/ReaderServerHandler.java
index 0b1be1f7..b3839da8 100644
--- a/src/main/java/net/iponweb/disthene/reader/server/ReaderServerHandler.java
+++ b/src/main/java/net/iponweb/disthene/reader/server/ReaderServerHandler.java
@@ -57,7 +57,6 @@ public void channelRead(ChannelHandlerContext ctx, Object message) {
                 }
             }
 
-
             if (handler != null) {
                 response = handler.handle(request);
             } else {
@@ -84,6 +83,8 @@ public void channelRead(ChannelHandlerContext ctx, Object message) {
             logger.debug("Invalid request: ", e);
             FullHttpResponse response = new DefaultFullHttpResponse(HTTP_1_1, INTERNAL_SERVER_ERROR, Unpooled.wrappedBuffer(("Ohoho.. We have a problem: " + e.getMessage()).getBytes()));
             ctx.write(response).addListener(ChannelFutureListener.CLOSE);
+        } finally {
+            ((HttpContent) message).content().release();
         }
     }