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); }