AnypointMQ-默认情况下消息是否持久化?
创始人
2024-08-23 00:00:35
0

在 Anypoint MQ 中,消息默认不是持久化的,这意味着任何未被消费的消息将在服务器重启时丢失。为了使消息持久化,需要将消息传递到持久化队列。以下是一个使用 Java 的 Anypoint MQ 示例,演示如何将消息发送到持久化队列。

MuleMessage message = org.mule.api.transport.PropertyScope.INVOCATION.getProperty("message");
MuleMessageFactory messageFactory = new DefaultMuleMessageFactory();
MuleContext muleContext = org.mule.api.transport.PropertyScope.INBOUND.getProperty("muleContext");
MuleClient muleClient = new MuleClient(muleContext);

Map mqProperties = new HashMap<>();
mqProperties.put(MuleProperties.MULE_MESSAGE_ID_PROPERTY, message.getUniqueId());
mqProperties.put(MuleProperties.MULE_REPLY_TO_PROPERTY, "persistent-queue");

MuleMessage mqMessage = messageFactory.create("", "UTF-8", message.getPayload(), mqProperties, muleContext);

muleClient.dispatch("vm://outbound", mqMessage);

在上面的示例中,“persistent-queue”是命名为“persistent-queue”的持久化队列的名称。将消息发送到该队列即可实现消息的持久化。

相关内容

热门资讯

四分钟辅助!wpk辅助,epo... 四分钟辅助!wpk辅助,epoker透视,机巧教程(有挂方式)1、下载好epoker透视透视辅助下载...
1分钟辅助!红龙poker辅助... 1分钟辅助!红龙poker辅助器免费观看,微扑克微乐辅助,诀窍教程(今日头条)1、在红龙poker辅...
9分钟辅助!佛手在线大菠萝智能... 9分钟辅助!佛手在线大菠萝智能辅助器,wpk有那种辅助吗,积累教程(确实有挂)1、佛手在线大菠萝智能...
4分钟辅助!hhpoker视频... 4分钟辅助!hhpoker视频巡查真的假的,aa poker辅助包,步骤教程(有挂技巧)hhpoke...
六分钟辅助!约局吧德州可以透视... 六分钟辅助!约局吧德州可以透视吗,拱趴游戏破解器,技法教程(有挂实锤)1、每一步都需要思考,不同水平...
第5分钟辅助!pokemmo内... 第5分钟辅助!pokemmo内置修改器,werplan外卦神器,方针教程(有挂详细)1)pokemm...
九分钟辅助!wepoker高级... 九分钟辅助!wepoker高级辅助,hh poker软件,机巧教程(有人有挂)1、下载好wepoke...
第十分钟辅助!wepoker透... 第十分钟辅助!wepoker透视脚本免费下载,约局吧作弊脚本,操作教程(有挂秘籍)1、全新机制【we...
4分钟辅助!wepoker透视... 4分钟辅助!wepoker透视脚本免费,pokemmo手机脚本,讲义教程(揭秘有挂)wepoker透...
第九分钟辅助!newpoker... 第九分钟辅助!newpoker怎么安装脚本,pokemmo手机辅助软件,方案教程(有挂技巧)1、该软...