@IntegrationFlow DSL 中的角色

Question

使用消息驱动通道适配器时，是否可以通过 IntegrationFlow dsl 指定用于领导选举的端点角色？

我可以使用 Jms dsl 创建 JMS 消息驱动端点并在端点上设置角色，但我看不到通过 IntegrationFlow dsl 指定角色的方法。

Answer 1

MessageProducerSpec

，

JmsMessageDrivenChannelAdapterSpec

的超类现在正在反弹，缺少该属性。

很快就会修复。下周发布。

同时你可以做这样的事情：

JmsMessageDrivenEndpoint jmsMessageDrivenEndpoint = 
                Jms.messageDrivenChannelAdapter(amqFactory)
                        .destination("some_destination")
                        .getObject();
        jmsMessageDrivenEndpoint.setRole("some_role");

        return IntegrationFlow
                .from(jmsMessageDrivenEndpoint)