首页 > 其他 > 详细

RabbitMQ 高阶用法 之 x-expire 过期时间设置

时间:2021-07-06 18:33:59      阅读:25      评论:0      收藏:0      [点我收藏+]
var conn = $@"host=ip:端口;virtualHost=/;username=用户名那个;password=密码;timeout=30;publisherConfirms=true";
                using (var bus = RabbitHutch.CreateBus(conn).Advanced)
                {

                    var message = new Message<泛型类>(泛型对象);
//声明队列后才能在RabbitMQ中看到 var queue = bus.QueueDeclare($@"队列name",(x)=>x.WithExpires(new TimeSpan(1000*60)) );//过期时间设置long类型毫秒值,先删除,不能存在同名队列,否则无法设置, bus.PublishAsync(Exchange.GetDefault(), $@"队列名", false, message) .ContinueWith(task => { if (task.IsCompleted && !task.IsFaulted) { //成功处理 } else { //失败处理 } }); }

  

RabbitMQ 高阶用法 之 x-expire 过期时间设置

原文:https://www.cnblogs.com/wuhailong/p/14977582.html

(0)
(0)
   
举报
评论 一句话评论(0
关于我们 - 联系我们 - 留言反馈 - 联系我们:wmxa8@hotmail.com
© 2014 bubuko.com 版权所有
打开技术之扣,分享程序人生!