private final PipelineDispatcher pipelineDispatcher;
public PipelineDispatcherForkInfoListener(PipelineDispatcher pipelineDispatcher) {
this.pipelineDispatcher = pipelineDispatcher;
}
public void starting(int forkId) {
<BUG>LOGGER.info("pipeline {}, fork {} : started", pipelineDispatcher.getPipeline().getConfig().getName(), forkId);
pipelineDispatcher.forkStarting(forkId);</BUG>
}
public void started(int forkId) {
}

private final PipelineDispatcher pipelineDispatcher;
public PipelineDispatcherForkInfoListener(PipelineDispatcher pipelineDispatcher) {
this.pipelineDispatcher = pipelineDispatcher;
}
public void starting(int forkId) {
LOGGER.info("pipeline {}, fork {} : started", pipelineDispatcher.getPipeline().getName(), forkId);
pipelineDispatcher.forkStarting(forkId);
}
public void started(int forkId) {
}
