123

ace-modules/ace-admin/src/main/java/com/github/wxiaoqi/security/admin/handler/WaterMQHandler.java

@@ -42,6 +42,7 @@ public class WaterMQHandler {
      */
     @RabbitListener(queues = ORDER_WATER_QUEUE)
     public void integralHandler(Message message, @Headers Map<String, Object> headers, Channel channel) {
+        log.info("拥金队列 messageJson："+ JSONUtil.parse(message));
         ExecutorService executorService = Executors.newCachedThreadPool();
         executorService.execute(new Runnable() {
             @Override