Set senderThreadReference in GelfHttpTransport

Graylog2 · Oct 9, 2019 · 56bf286 · 56bf286
1 parent 99e2f75
commit 56bf286
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/src/main/java/org/graylog2/gelfclient/transport/GelfHttpTransport.java b/src/main/java/org/graylog2/gelfclient/transport/GelfHttpTransport.java
@@ -56,6 +56,7 @@ public GelfHttpTransport(GelfConfiguration config) {
     protected void createBootstrap(final EventLoopGroup workerGroup) {
         final Bootstrap bootstrap = new Bootstrap();
         final GelfSenderThread senderThread = new GelfSenderThread(queue, config.getMaxInflightSends());
+        senderThreadReference.set(senderThread);
 
         bootstrap.group(workerGroup)
                 .channel(NioSocketChannel.class)