1

データベースからデータを取得し、サービスアクティベーターで簡単な変換を行う単純な DSL を 1 つ作成しました。

    @Bean
public IntegrationFlow mainFlow() {
    return IntegrationFlows.from("userChannel")
                .channel("queryChannel")
                .handle("sampleConvertor","convertUser")
                .get();

queryChannel は jdbc アウトバウンド ゲートウェイであり、sampleConverter はサービス アクティベーターです。

<int-jdbc:outbound-gateway query="select * from employee where employee_id=:payload"
request-channel="queryChannel" data-source="dataSource"/>

問題は、データベースからデータを取得した後、フローが serviceActivator に送られず、単にデータベースの応答を返すことです。

xml 構成では、以下のようにチェーン内でゲートウェイを呼び出していました。

<int:gateway id="query.gateway" request-channel="queryChannel"/>

ここで私が間違っていることを提案してください。前もって感謝します。

4

1 に答える 1