From 25eb1e99f86f6f738102677b340e72ce4490decc Mon Sep 17 00:00:00 2001 From: didfet Date: Tue, 10 Mar 2015 12:47:55 +0100 Subject: [PATCH] sendEvents method modification. --- .../info/fetter/logstashforwarder/protocol/LumberjackClient.java | 1 + 1 file changed, 1 insertion(+) diff --git a/src/main/java/info/fetter/logstashforwarder/protocol/LumberjackClient.java b/src/main/java/info/fetter/logstashforwarder/protocol/LumberjackClient.java index 2824e56..a271341 100644 --- a/src/main/java/info/fetter/logstashforwarder/protocol/LumberjackClient.java +++ b/src/main/java/info/fetter/logstashforwarder/protocol/LumberjackClient.java @@ -158,6 +158,7 @@ public class LumberjackClient { public int sendEvents(List eventList) throws IOException { int beginSequence = sequence; int numberOfEvents = eventList.size(); + sendWindowSizeFrame(numberOfEvents); List> keyValuesList = new ArrayList>(numberOfEvents); for(Event event : eventList) { keyValuesList.add(event.getKeyValues());