@@ -0,0 +1,980 @@
+package org.lapanen.stealth.si.process;%0A%0Aimport java.util.concurrent.ExecutorService;%0A%0Aimport org.springframework.integration.context.IntegrationObjectSupport;%0Aimport org.springframework.integration.core.MessageSource;%0Aimport org.springframework.integration.endpoint.MessageProducerSupport;%0Aimport org.springframework.integration.support.MessageBuilder;%0Aimport org.springframework.messaging.Message;%0A%0Apublic class ProcessInboundChannelAdapter implements MessageSource%3CProcessRunResult%3E %7B%0A%0A    private final ProcessExecutor processExecutor;%0A%0A    private final ExecutorService executorService;%0A%0A    public ProcessInboundChannelAdapter(final ProcessExecutor processExecutor, final ExecutorService executorService) %7B%0A        this.processExecutor = processExecutor;%0A        this.executorService = executorService;%0A    %7D%0A%0A    @Override%0A    public Message%3CProcessRunResult%3E receive() %7B%0A        return MessageBuilder.withPayload(processExecutor.execute(executorService)).build();%0A    %7D%0A%7D%0A

Add a simple MessageSource.