From ee4b5df5bceb46357373af1f5a386bec3124d164 Mon Sep 17 00:00:00 2001
From: Jochen Schalanda <jochen@graylog.com>
Date: Fri, 20 May 2016 19:14:22 +0200
Subject: [PATCH] Remove blocking write call when sending ACK

Closes #6
---
 src/main/java/org/graylog/plugins/beats/BeatsFrameDecoder.java | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/src/main/java/org/graylog/plugins/beats/BeatsFrameDecoder.java b/src/main/java/org/graylog/plugins/beats/BeatsFrameDecoder.java
index 8a9ce47..fb6b823 100644
--- 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);
         }
     }