Spring Integration reference guide指的是使用MessageStore實(shí)現(xiàn)為QueueChannel提供持久性.

提到了很多次,但是所有示例都使用XML配置,即

但是QueueChannel的實(shí)現(xiàn)沒(méi)有用于設(shè)置MessageStore的方法

那么,如何在不使用XML配置的情況下使用MessageStore創(chuàng)建QueueChannel？

解決方法:

對(duì)XML配置進(jìn)行反向工程,這就是答案.

您將MessageStore包裝在MessageGroupQueue中

所以看起來(lái)像這樣

@Bean

public MessageChannel messageStoreBackedChannel() {

return new QueueChannel(

new MessageGroupQueue(<>, "Group ID")

);

}

標(biāo)簽：spring-integration,java,spring

來(lái)源： https://codeday.me/bug/20191013/1906987.html

總結(jié)

以上是生活随笔為你收集整理的java中channelmessage,MessageStore支持的QueueChannel与Spring Integration Java Config的全部?jī)?nèi)容，希望文章能夠幫你解決所遇到的問(wèn)題。

如果覺(jué)得生活随笔網(wǎng)站內(nèi)容還不錯(cuò)，歡迎將生活随笔推薦給好友。