使用Java DSL设置pub-sub-domain

Question

我想将以下内容转换为spring-integration java dsl。

<int:channel id="partsSubscriberChannel" /> 

    <int-jms:message-driven-channel-adapter 
     id="jmsPartsInbound" 
     acknowledge="transacted" 
     destination-name="parts.topic" 
     channel="partsSubscriberChannel" 
     pub-sub-domain="true" 
     connection-factory="jmsConnectionFactory"/> 

这是我最高：

@Bean 
public MessageChannel partsErrorChannel() { 
    return new DirectChannel(); 
} 

@Bean 
public MessageChannel partsSubscriberChannel() { 
    return new DirectChannel(); 
}  

@Bean 
public IntegrationFlow partsSubscription(ConnectionFactory connectionFactory) { 
    return IntegrationFlows 
      .from(Jms.messageDriverChannelAdapter(connectionFactory) 
        .id("partsJmsSubscriber") 
        .destination(Topic.PARTS.getName()) 
        .outputChannel(partsSubscriberChannel()) 
        .errorChannel(partsErrorChannel())) 
      .get(); 
} 

如何设置pub-sub-domain和acknowledge XML属性？

Answer 1

这是当前不可直接使用DSL，但你可以在属性设置一个监听器容器连线...

@Bean 
public IntegrationFlow jmsMessageDriverFlowWithContainer() { 
    return IntegrationFlows 
      .from(Jms.messageDriverChannelAdapter(container()) 
        .id("foo")) 
        .errorChannel(errorChannel())) 
      .channel(outputChannel() 
      .get(); 
} 

@Bean 
public AbstractMessageListenerContainer container() { 
    DefaultMessageListenerContainer container = new DefaultMessageListenerContainer(); 
    container.setSessionTransacted(true); 
    container.setDestinationName(Topic.PARTS.getName()); 
    container.setPubSubDomain(true); 
    return container; 
}