Skip to content
This repository was archived by the owner on Mar 21, 2023. It is now read-only.

Commit cf55dcb

Browse files
author
Edmundo Alvarez
committed
Call finishProcessing in the right place
We should call `InterpreterListener.finishProcessing()` only once, but before that was not necessarily true, as it was being called inside a loop. Instead, now we call it in the same method as `startProcessing()`, after all processing has been finished. Fixes #51
1 parent 912802a commit cf55dcb

File tree

1 file changed

+2
-1
lines changed

1 file changed

+2
-1
lines changed

src/main/java/org/graylog/plugins/pipelineprocessor/processors/PipelineInterpreter.java

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -265,6 +265,8 @@ public Messages process(Messages messages, InterpreterListener interpreterListen
265265
}
266266
}
267267
}
268+
269+
interpreterListener.finishProcessing();
268270
// 7. return the processed messages
269271
return new MessageCollection(fullyProcessed);
270272
}
@@ -374,7 +376,6 @@ public List<Message> processForPipelines(Message message, String msgId, Set<Stri
374376
}
375377
}
376378

377-
interpreterListener.finishProcessing();
378379
// 7. return the processed messages
379380
return result;
380381
}

0 commit comments

Comments
 (0)