新政策

dating-agency-mall-server/src/main/java/com/qniao/dam/application/handler/revenuereward/RevenueRewardEventHandler.java

@@ -257,8 +257,8 @@ public class RevenueRewardEventHandler extends BaseApplicationService {
      *
      * @param mq
      */
-    @RabbitListener(bindings = @QueueBinding(value = @Queue(MqQueue.OPERATION_CENTER_CREATED),
-            exchange = @Exchange(value = MqExchange.OPERATION_CENTER_CREATED,
+    @RabbitListener(bindings = @QueueBinding(value = @Queue(MqQueue.MATCHMAKER_NOVICE_TASK_PROGRESS_FINISHED),
+            exchange = @Exchange(value = MqExchange.MATCHMAKER_NOVICE_TASK_PROGRESS_FINISHED,
                     type = ExchangeTypes.FANOUT)))
     public void handle(MatchmakerNoviceTaskProgressFinishedMQ mq) {
         try {

dating-agency-mall-server/src/main/java/com/qniao/dam/infrastructure/constant/MqExchange.java

@@ -31,4 +31,6 @@ public interface MqExchange {
     String OPERATION_CENTER_CREATED = "fanout.operationCenterCreated";
 
     String MATCHMAKER_INVITED = "fanout.MatchmakerInvited";
+
+    String MATCHMAKER_NOVICE_TASK_PROGRESS_FINISHED = "fanout.matchmakerNoviceTaskProgressFinished";
 }

dating-agency-mall-server/src/main/java/com/qniao/dam/infrastructure/constant/MqQueue.java

@@ -23,4 +23,6 @@ public interface MqQueue {
     String STORE_CREATED = MqExchange.STORE_CREATED + serviceName;
 
     String OPERATION_CENTER_CREATED = MqExchange.OPERATION_CENTER_CREATED + serviceName;
+
+    String MATCHMAKER_NOVICE_TASK_PROGRESS_FINISHED = MqExchange.MATCHMAKER_NOVICE_TASK_PROGRESS_FINISHED + serviceName;
 }