データベースからデータを取得し、サービスアクティベーターで簡単な変換を行う単純な 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"/>
ここで私が間違っていることを提案してください。前もって感謝します。