given:
        def protocol = Mock(WorkerLoggingProtocol)
        def logEvent = Mock(LogEvent)
        def styledTextOutputEvent = Mock(StyledTextOutputEvent)
        listener.setWorkerLoggingProtocol(protocol)

        when:
        listener.onOutput(logEvent)

        then:
        1 * protocol.sendOutputEvent(logEvent)

        when:
        listener.onOutput(styledTextOutputEvent)

    public WorkerLogEventListener() {
        this.workerLoggingProtocol = new AtomicReference<WorkerLoggingProtocol>();
    }

    public void setWorkerLoggingProtocol(WorkerLoggingProtocol workerLoggingProtocol) {
        this.workerLoggingProtocol.getAndSet(workerLoggingProtocol);
    }

        connection.useParameterSerializers(WorkerLoggingSerializer.create());
        WorkerLoggingProtocol workerLoggingProtocol = connection.addOutgoing(WorkerLoggingProtocol.class);
        workerLogEventListener.setWorkerLoggingProtocol(workerLoggingProtocol);
        loggingManager.addOutputEventListener(workerLogEventListener);
    }

    private void configureWorkerJvmMemoryInfoEvents(WorkerServices services, ObjectConnection connection) {