/**
 * An abstract build event sink.
 */
public interface BuildEventListener {

    void sessionStarted(ExecutionEvent event);

    void projectStarted(String projectId);

    void projectLogMessage(String projectId, String event);

    void projectFinished(String projectId);

    void executionFailure(String projectId, boolean halted, String exception);

    void mojoStarted(ExecutionEvent event);

    }

    @Override
    public void sessionStarted(ExecutionEvent event) {}

    @Override
    public void projectStarted(String projectId) {}

    @Override
    public void projectLogMessage(String projectId, String event) {
        log(event);
    }

    @Override
    public void projectFinished(String projectId) {}

    @Override

        MavenSimpleLogger.setLogSink(this::accept);
    }

    protected void accept(String message) {
        String projectId = MDC.get(KEY_PROJECT_ID);
        buildEventListener.projectLogMessage(projectId, message);
    }

    @Override
    public void close() throws Exception {
        MavenSimpleLogger.setLogSink(null);
    }