发圈处理

yj

2020-03-06 207dc8655711cddac2653e18b51e58a88dba2084

 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("资金消息投递成功");

   }



   /**