2016-08-10 3 views
1

私はこのような私の統合アプリでキューのように実行するためにRedisのリストを使用しています:ファクトリクラス

@Override 
protected IntegrationFlowDefinition<?> buildFlow() { 
    return this.from(this.redisQueueInboundGateway()) 
       .handle(...); 
} 

@Bean 
RedisQueueInboundGateway redisQueueInboundGateway() { 
    RedisQueueInboundGateway redisQueueInboundGateway = new RedisQueueInboundGateway(Queues.QUEUE_NAME, this.connectionFactory); 

    redisQueueInboundGateway.setSerializer(genericJackson2JsonRedisSerializer); 

    return redisQueueInboundGateway; 
} 

春の統合でAMQPのような任意のファクトリクラスがあります。これを達成するためにJava DSL?

答えて

1

これらのファクトリを必要に応じて追加します。

ご覧のとおり、これらのレディスアダプターはかなり使いやすく、あなたの定義ではきちんと正しいものです。

redisQueueInboundGateway()の方法から削除しても、それはprivateになります。 Spring統合Java DSLエンジンは、Beanの人口と初期化に注意します。

お気軽にGitHub issueをお寄せください!

+0

問題が作成されました(https://github.com/spring-projects/spring-integration-java-dsl/issues/102)。ありがとう! –

関連する問題