将 int-jms:publish-subscribe-channel 转换为 spring-integration dsl

Question

我正在尝试转换

<int-jms:publish-subscribe-channel id="partsPubSubChannel" topic-name="part.topic" connection-factory="jmsConnectionFactory"/>

到spring-集成dsl，这是我目前所拥有的。

@Autowired
@Qualifier("jmsConnectionFactory")
private ConnectionFactory jmsConnectionFactory;

@Bean
public IntegrationFlow partsPublishSubscribe() {
    return IntegrationFlows
            .from(Jms.publishSubscribeChannel(jmsConnectionFactory)).get();
}

如何设置 topic-name 属性？

Answer 1

@Bean
public IntegrationFlow pubSubFlow() {
    return IntegrationFlows.from(Jms.publishSubscribeChannel(this.jmsConnectionFactory)
                                    .destination("part.topic"))
                            .handle(...)
                             ...
                            .get();
}