Remove blocking write call when sending ACK

Closes #6
Graylog2 · May 20, 2016 · ee4b5df · ee4b5df
1 parent b27a48f
commit ee4b5df
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/src/main/java/org/graylog/plugins/beats/BeatsFrameDecoder.java b/src/main/java/org/graylog/plugins/beats/BeatsFrameDecoder.java
@@ -119,7 +119,7 @@ private void sendACK(Channel channel) throws IOException {
             buffer.writeInt((int) sequenceNum);
 
             LOG.trace("Sending ACK for sequence number {} on channel {}", sequenceNum, channel);
-            channel.write(buffer).awaitUninterruptibly();
+            channel.write(buffer);
         }
     }