*/

package org.gradle.launcher.daemon.protocol;

/**
 * Some arbitrary build event sent from build logic back to the build requester.
 */
public class BuildEvent extends Message {
    private final Object payload;

    public BuildEvent(Object payload) {
        this.payload = payload;
    }

    public Object getPayload() {
        return payload;
    }

    @Override

package org.gradle.api

import org.apache.tools.ant.BuildEvent
import org.apache.tools.ant.BuildListener

class RecordingAntBuildListener implements BuildListener {

    List<BuildEvent> buildStarted = []
    List<BuildEvent> buildFinished = []
    List<BuildEvent> targetStarted = []
    List<BuildEvent> targetFinished = []
    List<BuildEvent> taskStarted = []
    List<BuildEvent> taskFinished = []
    List<BuildEvent> messageLogged = []

    }

    @Override
    public void buildStarted(BuildEvent event) {
        // ignore
    }

    @Override
    public void buildFinished(BuildEvent event) {
        // ignore
    }

    @Override
    public void targetStarted(BuildEvent event) {
        // ignore
    }

    @Override
    public void targetFinished(BuildEvent event) {
        // ignore
    }

    @Override

        AntMessagePriority.ERROR   | Project.MSG_WARN    | LogLevel.INFO
        AntMessagePriority.ERROR   | Project.MSG_ERR     | LogLevel.ERROR
    }

    BuildEvent buildEvent(antPriority) {
        return Stub(BuildEvent) {
            _ * getPriority() >> antPriority
            _ * getTask() >> Stub(Task)
        }
    }

    static boolean isCategorizedAsAntLoggingAdapter(OutputEvent event) {

        private final Serializer<Object> payloadSerializer = new DefaultSerializer<>();

        @Override
        public void write(Encoder encoder, BuildEvent buildEvent) throws Exception {
            payloadSerializer.write(encoder, buildEvent.getPayload());
        }

        @Override
        public BuildEvent read(Decoder decoder) throws Exception {

    def serializer = DaemonMessageSerializer.create(new DefaultSerializer<BuildAction>())

    def "can serialize BuildEvent messages"() {
        expect:
        def event = new BuildEvent(["a", "b", "c"])
        def result = serialize(event, serializer)
        result instanceof BuildEvent
        result.payload == ["a", "b", "c"]
    }

    def "can serialize LogLevelChangeEvent messages"() {
        expect:

                } else if (object instanceof OutputMessage) {
                    outputEventListener.onOutput(((OutputMessage) object).getEvent());
                } else if (object instanceof BuildEvent) {
                    buildEventConsumer.dispatch(((BuildEvent) object).getPayload());
                } else {
                    return object;
                }
            }
        } finally {

import org.gradle.internal.concurrent.ManagedExecutor;
import org.gradle.internal.concurrent.Stoppable;
import org.gradle.internal.logging.events.OutputEvent;
import org.gradle.launcher.daemon.protocol.BuildEvent;
import org.gradle.launcher.daemon.protocol.BuildStarted;
import org.gradle.launcher.daemon.protocol.Cancel;
import org.gradle.launcher.daemon.protocol.CloseInput;
import org.gradle.launcher.daemon.protocol.DaemonUnavailable;

Class <org.gradle.launcher.daemon.protocol.Build> is not annotated (directly or via its package) with @org.gradle.api.NonNullApi in (Build.java:0)
Class <org.gradle.launcher.daemon.protocol.BuildEvent> is not annotated (directly or via its package) with @org.gradle.api.NonNullApi in (BuildEvent.java:0)
Class <org.gradle.launcher.daemon.protocol.BuildStarted> is not annotated (directly or via its package) with @org.gradle.api.NonNullApi in (BuildStarted.java:0)