4

我有这个:

 <si:poller max-messages-per-poll="10" id="defaultPoller" default="true">
  <si:interval-trigger interval="5000"/>
 </si:poller>
 <si:channel id="emailIn"/>
 <si:channel id="emailOut"/>

 <si:service-activator input-channel="emailIn" output-channel="emailOut" ref="mailService" method="recieveMessage"/>

 <si:gateway id="gateway" service-interface="com.blah.MailSender" default-request-channel="emailIn"/>

 <si:outbound-channel-adapter channel="emailOut" ref="mailService" method="recieveMessage" />

而且我认为我正在配置的是一个异步队列。我希望能够将消息放到它上面,然后让另一个线程拾取它们并稍后处理。但是,目前它似乎以同步的方式进行。

我做错了吗(显然是的),但想知道我在这个配置中是否缺少一些东西,或者我是否只是有错误的方法?

干杯

4

1 回答 1

4

默认情况下,Spring Integration 中的所有通道都是同步的。这是一个有意识的设计决策,例如,它将帮助您保持事务边界和安全上下文。当您想要进行异步切换时,您应该将任务执行器添加到您的调度程序或将队列添加到您的频道:

<channel>
  <dispatcher task-executor="pool"/>
</channel>

<channel>
  <queue capacity="10"/>
</channel>

查看参考指南中的通道配置,了解有关调度程序和队列的一些详细信息。另请参阅DirectChannel 部分和该部分下方的 ExecutorChannel 部分。

于 2010-06-28T12:32:52.427 回答