Просмотр исходного кода

sendEvents method modification.

didfet 11 лет назад
Родитель
Сommit
25eb1e99f8
1 измененных файлов с 1 добавлено и 0 удалено
  1. 1 0
      src/main/java/info/fetter/logstashforwarder/protocol/LumberjackClient.java

+ 1 - 0
src/main/java/info/fetter/logstashforwarder/protocol/LumberjackClient.java

@@ -158,6 +158,7 @@ public class LumberjackClient {
 	public int sendEvents(List<Event> eventList) throws IOException {
 	public int sendEvents(List<Event> eventList) throws IOException {
 		int beginSequence = sequence;
 		int beginSequence = sequence;
 		int numberOfEvents = eventList.size();
 		int numberOfEvents = eventList.size();
+		sendWindowSizeFrame(numberOfEvents);
 		List<Map<String,byte[]>> keyValuesList = new ArrayList<Map<String,byte[]>>(numberOfEvents);
 		List<Map<String,byte[]>> keyValuesList = new ArrayList<Map<String,byte[]>>(numberOfEvents);
 		for(Event event : eventList) {
 		for(Event event : eventList) {
 			keyValuesList.add(event.getKeyValues());
 			keyValuesList.add(event.getKeyValues());