admin
2024-03-08 0f704a4650edd60cea2e57778b6703509376a42c
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);
    }