getComponentDescript(); public String getId(); public org.codehaus.plexus.lifecycle.LifecycleHandler getLifecycleHandler(); protected void incrementConnectionC(); protected void decrementConnectionC(); protected boolean connected(); public int getConnections(); public void setup(org.codehaus.plexus.MutablePlexusContain, org.codehaus.plexus.lifecycle.LifecycleHandler, org.codehaus.plexus.component.repository.ComponentDescriptor); public void initialize(); protected Object createComponentInsta(org....

getComponentDescript(); public String getId(); public org.codehaus.plexus.lifecycle.LifecycleHandler getLifecycleHandler(); protected void incrementConnectionC(); protected void decrementConnectionC(); protected boolean connected(); public int getConnections(); public void setup(org.codehaus.plexus.MutablePlexusContain, org.codehaus.plexus.lifecycle.LifecycleHandler, org.codehaus.plexus.component.repository.ComponentDescriptor); public void initialize(); protected Object createComponentInsta(org....

getComponentDescript(); public String getId(); public org.codehaus.plexus.lifecycle.LifecycleHandler getLifecycleHandler(); protected void incrementConnectionC(); protected void decrementConnectionC(); protected boolean connected(); public int getConnections(); public void setup(org.codehaus.plexus.MutablePlexusContain, org.codehaus.plexus.lifecycle.LifecycleHandler, org.codehaus.plexus.component.repository.ComponentDescriptor); public void initialize(); protected Object createComponentInsta(org....

getComponentDescript(); public String getId(); public org.codehaus.plexus.lifecycle.LifecycleHandler getLifecycleHandler(); protected void incrementConnectionC(); protected void decrementConnectionC(); protected boolean connected(); public int getConnections(); public void setup(org.codehaus.plexus.MutablePlexusContain, org.codehaus.plexus.lifecycle.LifecycleHandler, org.codehaus.plexus.component.repository.ComponentDescriptor); public void initialize(); protected Object createComponentInsta(org....

        private final BlockingQueue<InterHubMessage> outgoingB = new LinkedBlockingQueue<>()

        RemoteConnection<InterHubMessage> getConnectionA() {
            return new RemoteConnection<InterHubMessage>() {
                void dispatch(InterHubMessage message) {
                    outgoingA.put(message)
                }

                @Override

        System.out.println("Child SCM URL is: " + project1.getScm().getUrl());
        System.out.println();
        System.out.println("Parent SCM connection is: " + project0.getScm().getConnection());
        System.out.println("Child SCM connection is: " + project1.getScm().getConnection());
        System.out.println();
        System.out.println(
                "Parent SCM developer connection is: " + project0.getScm().getDeveloperConnection());

                }
                workerProcess.getConnection().addIncoming(ResponseProtocol.class, receiver);
                workerProcess.getConnection().useJavaSerializationForParameters(workerImplementation.getClassLoader());
                workerProcess.getConnection().useParameterSerializers(RequestSerializerRegistry.create(workerImplementation.getClassLoader(), argumentSerializers));

    @Override
    public void execute(final DaemonCommandExecution execution) {
        // Watch for the client disconnecting before we call stop()
        execution.getConnection().onDisconnect(new Runnable() {
            @Override
            public void run() {
                LOGGER.warn("thread {}: client disconnection detected, canceling the build", Thread.currentThread().getId());

    @Override
    public void execute(final DaemonCommandExecution execution) {
        forwarder.forwardInput(stdinHandler -> {
            execution.getConnection().onStdin(stdinHandler);
            try {
                execution.proceed();
            } finally {
                execution.getConnection().onStdin(null);
            }
            return null;
        });
    }

    private static final Logger LOGGER = Logging.getLogger(HandleCancel.class);

    @Override
    public void execute(final DaemonCommandExecution execution) {
        execution.getConnection().onCancel(new Runnable() {
            @Override
            public void run() {
                LOGGER.info("HandleCancel processing {}", execution.getCommand());