diff --git a/src/main/java/teetime/framework/Analysis.java b/src/main/java/teetime/framework/Analysis.java index 698af379f62df4e56eff0380a03f01064618d385..cc143dcd7fd4fc9981719641e5b9dafe39b10e48 100644 --- a/src/main/java/teetime/framework/Analysis.java +++ b/src/main/java/teetime/framework/Analysis.java @@ -267,14 +267,14 @@ public final class Analysis<T extends AnalysisConfiguration> implements Uncaught private void sendInitializingSignal() { for (RunnableProducerStage runnable : producerRunnables) { InitializingSignal signal = new InitializingSignal(); - runnable.initializeProducer(signal); + runnable.sendInitializingSignal(signal); } } private void sendStartingSignal() { for (RunnableProducerStage runnable : producerRunnables) { StartingSignal signal = new StartingSignal(); - runnable.startProducer(signal); + runnable.sendStartingSignal(signal); } } diff --git a/src/main/java/teetime/framework/RunnableProducerStage.java b/src/main/java/teetime/framework/RunnableProducerStage.java index 4c6c9c7cb9fe478544e8df6fb0cec1bbf652d73d..8275f07f3808bf1d07e36d57bc3543e6958d5a5c 100644 --- a/src/main/java/teetime/framework/RunnableProducerStage.java +++ b/src/main/java/teetime/framework/RunnableProducerStage.java @@ -44,12 +44,12 @@ final class RunnableProducerStage extends AbstractRunnableStage { this.stage.onSignal(terminatingSignal, null); } - public void initializeProducer(final InitializingSignal signal) { + public void sendInitializingSignal(final InitializingSignal signal) { this.stage.onSignal(signal, null); initArrived = true; } - public void startProducer(final StartingSignal signal) { + public void sendStartingSignal(final StartingSignal signal) { this.stage.onSignal(signal, null); startArrived = true; }