Spring Integration - Планиране на задание от конфигурационен файл

Изобщо не е ясно какво имате предвид; разделяте етикет; го маршрутизирате, но искате да го „планирате“ със скорост в XML. Не е ясно какво имате предвид под "график" тук - обикновено всяко съобщение се обработва веднъж, а не няколко пъти по график.

Както казах, не разбирам какво трябва да направите, но smart poller може да е подходящ.

Друга възможност е забавянето, където сумата на закъснението може да бъде извлечена от съобщението.

РЕДАКТИРАНЕ

Тъй като вашите „услуги“ изглежда не приемат никакви входни данни, изглежда, че просто трябва да конфигурирате/стартирате <inbound-channel-adapter/> за всяка услуга и след това да я стартирате въз основа на аргументите в XML.

<int:inbound-channel-adapter id="service1" channel="foo"
            auto-startup="false"
            ref="service1Bean" method="execute">
     <poller fixed-delay="1000" />
</int:inbound-channel-adapter/>

Бележка auto-startup="false".

Сега, в кода, който получава разделянето

@Autowired
SourcePollingChannelAdapter service1;

...

public void startService1(Node node) {

    ...

    service1.setTrigger(new PeridicTrigger(...));

    service1.start();

    ...
}

Не знам дали това е правилният начин за прилагане на потока, но написах следния код:

applicationContext.xml

<context:component-scan base-package="it.mypkg" />

<!-- Expression to extract interval from XML tag -->    
<si-xml:xpath-expression id="selectIntervalXpath" expression="//*/@interval" />

<si:channel id="rootChannel" />

<!-- Split each tag to redirect on router -->
<si-xml:xpath-splitter id="mySplitter" input-channel="rootChannel" output-channel="routerChannel" create-documents="true">
    <si-xml:xpath-expression expression="//service|//activity" />
</si-xml:xpath-splitter>

<!-- Route each tag to the appropiate channel -->
<si-xml:xpath-router id="router" input-channel="routerChannel" evaluate-as-string="true">
    <si-xml:xpath-expression expression="concat(name(./node()), 'Channel')" />
</si-xml:xpath-router>

<!-- Activator for Service Tag -->
<si:service-activator input-channel="serviceChannel" method="schedule">
    <bean class="it.mypkg.Service" />
</si:service-activator>

<!-- Activator for Activity Tag -->
<si:service-activator input-channel="activityChannel" method="schedule">
    <bean class="it.mypkg.Activity" />
</si:service-activator>

<!-- Task scheduler -->
<task:scheduler id="taskScheduler" pool-size="10"/>

Всеки таг ще разшири клас операции (за да се избегне дублиране на код при инжектиране на боб)

Операция.java

public abstract class Operation {

    protected TaskScheduler taskScheduler;
    protected XPathExpression selectIntervalXpath;

    abstract public void schedule(Node document);

    @Autowired
    public void setTaskScheduler(TaskScheduler taskScheduler) {
        this.taskScheduler= taskScheduler;
    }

    public TaskScheduler getTaskScheduler() {
        return this.taskScheduler;
    }

    @Autowired
    public void setSelectIntervalXpath(XPathExpression selectIntervalXpath) {
        this.selectIntervalXpath = selectIntervalXpath;
    }

    public XPathExpression getSelectIntervalXPath() {
        return this.selectIntervalXpath;
    }
}

И пример за клас на услугата (който обработва всички тагове service, предоставени в .xml)

public class Service extends Operation {

    private static final Logger log = Logger.getLogger(Service.class);

    @Override
    public void schedule(Node document) {
        log.debug("Scheduling Service");
        long interval = Long.parseLong(this.selectIntervalXpath.evaluateAsString(document));

        this.taskScheduler.scheduleAtFixedRate(new ServiceRunner(), interval);
    }

    private class ServiceRunner implements Runnable {

        public void run() {
            log.debug("Running...");

        }
    }
}

Сега, за да продължа моя поток, ще трябва да намеря начин да пренасоча изхода на всяко задание към Spring Integration (applicationContext.xml).