From bf1a7eca3284d4b575cca3234a6d130b0bd6bb13 Mon Sep 17 00:00:00 2001
From: Mikko Kortelainen <1@teragrep.com>
Date: Tue, 13 Sep 2022 13:08:50 +0300
Subject: [PATCH] add socket close after processing has stopped

---
 src/main/java/com/teragrep/rlp_03/SocketProcessor.java | 5 ++++-
 1 file changed, 4 insertions(+), 1 deletion(-)

diff --git a/src/main/java/com/teragrep/rlp_03/SocketProcessor.java b/src/main/java/com/teragrep/rlp_03/SocketProcessor.java
index fb37bca5..711dac45 100644
--- a/src/main/java/com/teragrep/rlp_03/SocketProcessor.java
+++ b/src/main/java/com/teragrep/rlp_03/SocketProcessor.java
@@ -170,7 +170,10 @@ public void run() {
             for (Thread thread : messageSelectorThreadList) {
                 thread.join();
             }
-        } catch (InterruptedException e) {
+
+            serverSocket.close();
+        } catch (InterruptedException | IOException e) {
+            // FIXME
             e.printStackTrace();
         }
     }