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 | 2 ++
1 files changed, 2 insertions(+), 0 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 98bf479..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);
}
--
Gitblit v1.8.0