我有这个:
<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" />
我认为我正在配置的是一个异步队列。我希望能够将消息放到它上面,然后让另一个线程接收它们并稍后处理。但是,目前它似乎是以同步方式进行的。
我做错了吗(显然是的),但想知道我是否在这个配置中遗漏了什么,或者我是否只是采用了错误的方法?
干杯
最佳答案
默认情况下,Spring Integration 中的所有 channel 都是同步的。这是一个有意识的设计决策,例如,它将帮助您保持事务边界和安全上下文。当你想进行异步切换时,你应该向你的调度程序添加一个任务执行器或向你的 channel 添加一个队列:
<channel>
<dispatcher task-executor="pool"/>
</channel>
<channel>
<queue capacity="10"/>
</channel>
看channel configurations在引用指南中了解有关调度程序和队列的一些详细信息。另见 section on DirectChannel以及下面关于 ExecutorChannel 的部分。
关于java - Spring - 用于发送邮件的异步队列,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/3117775/