MQ消息发送日志

cash-common/cash-common-mq/src/main/java/com/czg/config/RabbitPublisher.java

@@ -23,6 +23,7 @@ public class RabbitPublisher {
     /**
      * 订单取消消息
      * 目前 用来回滚库存
+     *
      * @param orderId 订单id
      */
     public void sendOrderCancelMsg(String orderId) {
@@ -31,6 +32,7 @@ public class RabbitPublisher {
 
     /**
      * 库存损耗消息
+     *
      * @param orderId 订单id
      */
     public void sendOrderStockMsg(String orderId) {
@@ -39,6 +41,7 @@ public class RabbitPublisher {
 
     /**
      * 退款库存回滚消息(未校验商品退款是否退回库存)
+     *
      * @param refundMap Map <Long,BigDecimal> 商品Id,退单数量
      */
     public void sendOrderRefundMsg(String refundMap) {
@@ -47,6 +50,7 @@ public class RabbitPublisher {
 
     /**
      * 订单打印消息
+     *
      * @param orderId    订单id
      * @param printOrder 是否打印结算单
      */
@@ -62,6 +66,7 @@ public class RabbitPublisher {
 
     /**
      * 退款订单打印消息
+     *
      * @param orderId 订单id
      */
     public void sendOrderReturnPrintMsg(String orderId) {
@@ -89,6 +94,7 @@ public class RabbitPublisher {
 
     /**
      * 排队叫号小票打印
+     *
      * @param id 叫号队列id
      */
     public void printCallNumTicket(Long id) {
@@ -97,6 +103,7 @@ public class RabbitPublisher {
 
 
     private void sendMsg(String queue, String msg) {
+        log.info("开始发送mq消息,exchange:{}, queue: {}, msg: {}", activeProfile + "-" + RabbitConstants.Exchange.CASH_EXCHANGE, activeProfile + "-" + queue, msg);
         rabbitTemplate.convertAndSend(activeProfile + "-" + RabbitConstants.Exchange.CASH_EXCHANGE, activeProfile + "-" + queue, msg);
     }