diff --git a/src/main/java/com/exactpro/th2/estore/EventProcessor.java b/src/main/java/com/exactpro/th2/estore/EventProcessor.java index 6afc124..9f7dd7a 100644 --- a/src/main/java/com/exactpro/th2/estore/EventProcessor.java +++ b/src/main/java/com/exactpro/th2/estore/EventProcessor.java @@ -109,15 +109,6 @@ public void close() { } } - - private void checkAndRespond(AtomicBoolean responded, Supplier confirmationFunction) { - synchronized(responded) { - if (!responded.get()) - responded.set(confirmationFunction.get()); - } - } - - private void storeSingleEvents(List events, Confirmation confirmation) { Callback persistorCallback = new ProcessorCallback(confirmation, events.size()); @@ -257,5 +248,12 @@ public void onFail(TestEventToStore persistedEvent) { completed.put(persistedEvent, persistedEvent); } } + + private void checkAndRespond(AtomicBoolean responded, Supplier confirmationFunction) { + synchronized(responded) { + if (!responded.get()) + responded.set(confirmationFunction.get()); + } + } } }