Как создать bean-компоненты из интеграции с xml

Question

У меня есть код, который должен быть переписан для bean-компонентов в Java, потому что мне нужно создать несколько потоков интеграции вместо одного.Для каждого клиента.

Я хочу создать компонент JdbcPollingChannelAdapter для каждого клиента, использующего postProcessBeanFactory, но я не знаю, как добавить для него канал.

<beans profile="retryProcessing">
        <bean id="jdbc-poll-for-email" class="org.springframework.integration.jdbc.JdbcPollingChannelAdapter">
            <constructor-arg value="dataSource"/>
            <constructor-arg value="SELECT RowID..."/>
            <property name="updateSql" value="UPDATE ${customer.catalog}...."/>
        </bean>
    </beans>

<int-jdbc:inbound-channel-adapter
            query="SELECT RowID, DocumentID..."
            channel="email.Channel" data-source="dataSource"
            update="UPDATE ${customer.catalog} SET Status=....">
        <int:poller fixed-rate="${emailAdvice.retry.period:60}" time-unit="SECONDS"/>
    </int-jdbc:inbound-channel-adapter>
    <int:channel id="email.Channel"/>
    <int:chain input-channel="email.Channel" output-channel="email.headerEnricherChannel">
        <int:splitter id="splitter"/>
        <int:header-enricher>
            <int:header name="inboxType" expression="payload.get('InboxType')"/>
            <int:header name="rowId" expression="payload.get('RowID')"/>
        </int:header-enricher>
        <int:transformer>
            <bean class="RowTransformer">
                <constructor-arg ref="transformRow"/>
            </bean>
        </int:transformer>
    </int:chain>

Answer 1

В этом разделе руководства показано, как найти классы, используемые для канального адаптера.

В частности, вам нужно SourcePollingChannelAdapter и JdbcPollingChannelAdapter для каждого.

Также см. java DSL и, в частности, Динамическая интеграция и потоки интеграции во время выполнения для получения информации о предпочтительном механизме программной сборки потоков.