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