Skip to content

W
wecloud_im_server
Commit 3fdcae4e by Future
Options

发送通知栏消息异常捕获

parent 47b8b698
Showing with 9 additions and 4 deletions
core/src/main/java/com/wecloud/im/mq/MqSender.java
...@@ -80,10 +80,15 @@ public class MqSender { ...@@ -80,10 +80,15 @@ public class MqSender {
* @return * @return
*/ */
public SendResult orderSend(String topic, String tag, PushDTO pushDTO) { public SendResult orderSend(String topic, String tag, PushDTO pushDTO) {
log.info("mq按顺序发送topic: {} tag: {} 推送内容: {}", topic, tag, JSON.toJSONString(pushDTO)); try {
SendResult sendResult = rocketMqProducerService.orderSend(topic, tag, JSON.toJSONString(pushDTO), 1); log.info("mq按顺序发送topic: {} tag: {} 推送内容: {}", topic, tag, JSON.toJSONString(pushDTO));
log.info("mq按顺序发送topic: {} tag: {} 返回结果: {}", topic, tag, JSON.toJSONString(sendResult)); SendResult sendResult = rocketMqProducerService.orderSend(topic, tag, JSON.toJSONString(pushDTO), 1);
return sendResult; log.info("mq按顺序发送topic: {} tag: {} 返回结果: {}", topic, tag, JSON.toJSONString(sendResult));
return sendResult;
} catch (Exception e) {
log.info("发送通知栏消息异常 ", e);
return null;
}
} }
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment