withReportProblemTask """
            problems.forNamespace('org.example.plugin').reporting {
                it.details('Wrong API usage')
            }
        """

        when:
        run('reportProblem')

        then:
        verifyAll(receivedProblem) {
            definition.id.fqid == 'problems-api:missing-id'
            definition.id.displayName == 'Problem id must be specified'

                    getProblems().forNamespace("org.example.plugin").reporting(builder ->
                        builder.id("type", "label")
                    );
                    project.getTasks().register("reportProblem", t -> {
                        t.doLast(t2 -> {

                        });
                    });
                }
            }
        """
        file("plugins/build.gradle") << """

                    $taskActionMethodBody
                }
            }

            tasks.register("reportProblem", ProblemReportingTask)
        """
    }

    def runTask() {
        def listener = new ProblemProgressListener()
        withConnection { connection ->
            connection.newBuild().forTasks('reportProblem')
                .addProgressListener(listener)
                .run()
        }

    }

    def runTask() {
        def listener = new ProblemProgressListener()
        withConnection { connection ->
            connection.newBuild().forTasks('reportProblem')
                .addProgressListener(listener)
                .run()
        }
        return listener.problems
    }

    @TargetGradleVersion(">=6.9.4 <=8.5")

        } catch (InterruptedException e) {
            throw UncheckedException.throwAsUncheckedException(e);
        }
    }

    @Override
    public void reportProblem(Problem problem, OperationIdentifier id) {
        problemProtocol.reportProblem(problem, id);
    }

    @Override
    public void sendOutputEvent(LogEvent event) {
        loggingProtocol.sendOutputEvent(event);
    }

    @Override

                    getWorkerExecutor().${isolationMode}().submit(ProblemWorkerTask.class) {}
                }
            }

            tasks.register("reportProblem", ProblemTask)
        """

        when:
        run("reportProblem")

        then:
        verifyAll(receivedProblem) {
            operationId == Long.parseLong(buildOperationIdFile.text)

    }

    def runTask() {
        def listener = new ProblemProgressListener()
        withConnection { connection ->
            connection.newBuild().forTasks('reportProblem')
                .addProgressListener(listener)
                .run()
        }
        return listener.problems
    }

                @TaskAction
                void run() {
                    $taskActionMethodBody
                }
            }

            tasks.register("reportProblem", ProblemReportingTask)
        """
    }

import javax.annotation.Nullable;

/**
 * Interface used between the worker and the daemon to report problems.
 */
public interface WorkerProblemProtocol {
    void reportProblem(Problem problem, @Nullable OperationIdentifier id);

 * This implementation will take care of reporting problems received from the worker.
 */
@NonNullApi
public class DefaultWorkerProblemProtocol implements WorkerProblemProtocol {

    @Override
    public void reportProblem(Problem problem, OperationIdentifier id) {
        InternalProblemReporter problemsService = ProblemsProgressEventEmitterHolder.get().getInternalReporter();
        problemsService.report(problem, id);
    }