So geben Sie taskExecutor in publishSubscribe() an

Question

Wie kann die folgende XML-Konfiguration in die entsprechende Spring-Integration java-dsl "übersetzt" werden?

<int:publish-subscribe-channel id="channel" task-executor="myex"> 
</int:publish-subscribe-channel> 

<task:executor id="myex" pool-size="10"></task:executor> 

Ich habe die DSL Reference Guide gelesen, aber noch kann es nicht herausgefunden.

Answer 1

MessageChannels Kapitel verweist auf die MessageChannels Fabrik. So übersetzt <publish-subscribe-channel> XML config Java Config wie:

@Bean 
public MessageChannel channel() { 
    return MessageChannels.publishSubscribe(myExecutor()).get(); 
} 

Obwohl Sie das gleiche erreichen können nur mit roher Java config:

@Bean 
public MessageChannel channel() { 
    return new PublishSubscribeChannel(myExecutor()); 
}