java - 如何通过 xml 集成创建 bean

Question

我的代码应该重写为 java 中的 beans，因为我需要创建多个集成流而不是一个。对于每一位客户。

我想使用 postProcessBeanFactory 为每个客户创建 JdbcPollingChannelAdapter bean，但我不知道如何为其添加 channel 。

<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

This section of the manual显示如何查找 channel 适配器涉及的类。

具体来说，每个都需要一个 SourcePollingChannelAdapter 和一个 JdbcPollingChannelAdapter。

另请参阅the java DSL特别是Dynamic and Runtime Integration flows以编程方式组装流的首选机制。