From 5e7b0ed4a154ad067cbcf4aa1a1c7cce32f9864c Mon Sep 17 00:00:00 2001
From: admin <weikou2014>
Date: 星期五, 26 四月 2024 18:02:17 +0800
Subject: [PATCH] 唯品会链接解析升级
---
fanli/src/main/java/com/yeshi/fanli/util/mq/cmq/TDMQUtil.java | 10 +++++++++-
1 files changed, 9 insertions(+), 1 deletions(-)
diff --git a/fanli/src/main/java/com/yeshi/fanli/util/mq/cmq/TDMQUtil.java b/fanli/src/main/java/com/yeshi/fanli/util/mq/cmq/TDMQUtil.java
index 895408e..c841a5c 100644
--- a/fanli/src/main/java/com/yeshi/fanli/util/mq/cmq/TDMQUtil.java
+++ b/fanli/src/main/java/com/yeshi/fanli/util/mq/cmq/TDMQUtil.java
@@ -193,6 +193,7 @@
request.setQueueName(queueName);
request.setMsgContent(msg);
request.setDelaySeconds(delaySeconds);
+
try {
SendCmqMsgResponse response = getMsgClient().SendCmqMsg(request);
return response.getMsgId();
@@ -202,6 +203,7 @@
return null;
}
+
public String sendMsg(String queueName, String msg) {
return this.sendMsg(queueName, msg, 0L);
}
@@ -210,7 +212,13 @@
// 娑堣垂娑堟伅
public Message recieveMsg(String queueName) throws Exception {
com.qcloud.cmq.Queue queue = account.getQueue(queueName);
- return queue.receiveMessage();
+ try {
+ return queue.receiveMessage();
+ } catch (Exception e) {
+ if (e.getMessage() != null && !e.getMessage().contains("no message"))
+ e.printStackTrace();
+ }
+ return null;
}
/**
--
Gitblit v1.8.0