diff --git a/src/main/java/com/m2pool/lease/service/impl/LeaseShopServiceImpl.java b/src/main/java/com/m2pool/lease/service/impl/LeaseShopServiceImpl.java
index 8215e8a..9d3beed 100644
--- a/src/main/java/com/m2pool/lease/service/impl/LeaseShopServiceImpl.java
+++ b/src/main/java/com/m2pool/lease/service/impl/LeaseShopServiceImpl.java
@@ -726,8 +726,11 @@ public class LeaseShopServiceImpl extends ServiceImpl<LeaseShopMapper, LeaseShop
                     .user_email(username+"--"+authId)
                     .build();
             try {
-                //发送提现消息
-                rabbitTemplate.convertAndSend(PAY_WITHDRAW_QUEUE,message);
+                //发送提现消息，设置 8 分钟 TTL
+                rabbitTemplate.convertAndSend(PAY_WITHDRAW_QUEUE, message, msg -> {
+                    msg.getMessageProperties().setExpiration(String.valueOf(480 * 1000));
+                    return msg;
+                });
                 OperationLogAspect.addExtraLogParam("提现金额", balanceVo.getAmount());
                 OperationLogAspect.addExtraLogParam("手续费", serviceCharge.toString());
                 OperationLogAspect.addExtraLogParam("消息ID", queueId);
diff --git a/src/main/java/com/m2pool/lease/service/impl/LeaseUserServiceImpl.java b/src/main/java/com/m2pool/lease/service/impl/LeaseUserServiceImpl.java
index caa6374..42e281f 100644
--- a/src/main/java/com/m2pool/lease/service/impl/LeaseUserServiceImpl.java
+++ b/src/main/java/com/m2pool/lease/service/impl/LeaseUserServiceImpl.java
@@ -1305,8 +1305,11 @@ public class LeaseUserServiceImpl extends ServiceImpl<LeaseUserMapper, LeaseUser
                     .build();
             try {
 
-                //发送 提现 消息
-                rabbitTemplate.convertAndSend(PAY_WITHDRAW_QUEUE,message);
+                //发送 提现 消息，设置 8 分钟 TTL
+                rabbitTemplate.convertAndSend(PAY_WITHDRAW_QUEUE, message, msg -> {
+                    msg.getMessageProperties().setExpiration(String.valueOf(480 *1000));
+                    return msg;
+                });
                 OperationLogAspect.addExtraLogParam("提现金额", balanceVo.getAmount().toString());
                 OperationLogAspect.addExtraLogParam("手续费", serviceCharge.toString());
                 OperationLogAspect.addExtraLogParam("消息ID", queueId);