admin
2020-05-06 24a8d17e007545f7426c48352109aa1a9c6587ee
fanli/src/main/java/com/yeshi/fanli/util/cmq/UserMoneyChangeCMQManager.java
@@ -34,8 +34,15 @@
      for (int i = 0; i < subscripts.length; i++) {
         String queueName = queues[i];
         cmqUtil.createQueue(queueName);
         cmqUtil.subscribeTopic(TOPIC_NAME, subscripts[i], queueName);
         try {
            cmqUtil.createQueue(queueName);
         } catch (Exception e) {
         }
         try {
            cmqUtil.subscribeTopic(TOPIC_NAME, subscripts[i], queueName);
         } catch (Exception e) {
         }
      }
   }
@@ -54,7 +61,7 @@
      if (dto == null)
         return;
      cmqUtil.publishTopicMessage(TOPIC_NAME, new Gson().toJson(dto));
      LogHelper.test("邀请消息投递成功");
      LogHelper.test("资金消息投递成功");
   }
   /**