close connection after consumer close

wangxiaolin · brainlag · commit 6fc435fa60fa · 2018-09-29T22:56:14.000+02:00
diff --git a/src/main/java/com/github/brainlag/nsq/NSQConsumer.java b/src/main/java/com/github/brainlag/nsq/NSQConsumer.java
@@ -158,6 +158,7 @@ private void cleanClose() {
                         throw new IllegalStateException(err);
                     }
                 }
+                connection.close();
             }
         } catch (final TimeoutException e) {
             LogManager.getLogger(this).warn("No clean disconnect", e);

Original file line number	Diff line number	Diff line change
`@@ -158,6 +158,7 @@ private void cleanClose() {`
`158`	`158`	`throw new IllegalStateException(err);`
`159`	`159`	`}`
`160`	`160`	`}`
	`161`	`+ connection.close();`
`161`	`162`	`}`
`162`	`163`	`} catch (final TimeoutException e) {`
`163`	`164`	`LogManager.getLogger(this).warn("No clean disconnect", e);`