diff --git a/dating-agency-mall-server/src/main/java/com/qniao/dam/application/handler/revenuereward/RevenueRewardEventHandler.java b/dating-agency-mall-server/src/main/java/com/qniao/dam/application/handler/revenuereward/RevenueRewardEventHandler.java
index 0dfaf30..9265595 100644
--- a/dating-agency-mall-server/src/main/java/com/qniao/dam/application/handler/revenuereward/RevenueRewardEventHandler.java
+++ b/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 {
diff --git a/dating-agency-mall-server/src/main/java/com/qniao/dam/infrastructure/constant/MqExchange.java b/dating-agency-mall-server/src/main/java/com/qniao/dam/infrastructure/constant/MqExchange.java
index 3f90105..fde3735 100644
--- a/dating-agency-mall-server/src/main/java/com/qniao/dam/infrastructure/constant/MqExchange.java
+++ b/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";
 }
diff --git a/dating-agency-mall-server/src/main/java/com/qniao/dam/infrastructure/constant/MqQueue.java b/dating-agency-mall-server/src/main/java/com/qniao/dam/infrastructure/constant/MqQueue.java
index fb5c7ee..1752357 100644
--- a/dating-agency-mall-server/src/main/java/com/qniao/dam/infrastructure/constant/MqQueue.java
+++ b/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;
 }