spring-integration-redis 组件的工厂类

Question

我正在使用 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;
}

Spring Integration Java DSL中有没有像AMQP这样的工厂类来实现这个？

Answer 1

我们根据需要为目标协议添加这些工厂。

尽管如您所见，这些 Redis 适配器使用起来非常简单，并且在您的定义中这样做非常正确。

只有一条评论：即使您从 redisQueueInboundGateway() 方法中删除 @Bean 并使其变为 private，它也将起作用。 Spring Integration Java DSL 引擎将为您处理 bean 填充和初始化。

请随时就此事提出GitHub issue！