~queue.consumer.handler;

liquidnet-bus-service/liquidnet-service-consumer-all/liquidnet-service-consumer-kylin/src/main/java/com/liquidnet/service/consumer/kylin/receiver/ConsumerOrderClose1RdsReceiver.java

@@ -4,7 +4,7 @@ import com.liquidnet.service.base.constant.MQConst;
 import org.springframework.stereotype.Component;
 
 @Component
-public class ConsumerOrderClose1RdsReceiver extends AbstractSqlRedisReceiver {
+public class ConsumerOrderClose1RdsReceiver extends AbstractOrderCloseReceiver {
     @Override
     protected String getRedisStreamKey() {
         return MQConst.GoblinQueue.GOBLIN_UN_PAY_1.getKey();

liquidnet-bus-service/liquidnet-service-consumer-all/liquidnet-service-consumer-kylin/src/main/java/com/liquidnet/service/consumer/kylin/receiver/ConsumerOrderClose2RdsReceiver.java

@@ -4,7 +4,7 @@ import com.liquidnet.service.base.constant.MQConst;
 import org.springframework.stereotype.Component;
 
 @Component
-public class ConsumerOrderClose2RdsReceiver extends AbstractSqlRedisReceiver {
+public class ConsumerOrderClose2RdsReceiver extends AbstractOrderCloseReceiver {
     @Override
     protected String getRedisStreamKey() {
         return MQConst.GoblinQueue.GOBLIN_UN_PAY_2.getKey();

liquidnet-bus-service/liquidnet-service-consumer-all/liquidnet-service-consumer-kylin/src/main/java/com/liquidnet/service/consumer/kylin/receiver/ConsumerOrderClose3RdsReceiver.java

@@ -4,7 +4,7 @@ import com.liquidnet.service.base.constant.MQConst;
 import org.springframework.stereotype.Component;
 
 @Component
-public class ConsumerOrderClose3RdsReceiver extends AbstractSqlRedisReceiver {
+public class ConsumerOrderClose3RdsReceiver extends AbstractOrderCloseReceiver {
     @Override
     protected String getRedisStreamKey() {
         return MQConst.GoblinQueue.GOBLIN_UN_PAY_3.getKey();

liquidnet-bus-service/liquidnet-service-consumer-all/liquidnet-service-consumer-kylin/src/main/java/com/liquidnet/service/consumer/kylin/receiver/ConsumerOrderClose4RdsReceiver.java

@@ -4,7 +4,7 @@ import com.liquidnet.service.base.constant.MQConst;
 import org.springframework.stereotype.Component;
 
 @Component
-public class ConsumerOrderClose4RdsReceiver extends AbstractSqlRedisReceiver {
+public class ConsumerOrderClose4RdsReceiver extends AbstractOrderCloseReceiver {
     @Override
     protected String getRedisStreamKey() {
         return MQConst.GoblinQueue.GOBLIN_UN_PAY_4.getKey();

liquidnet-bus-service/liquidnet-service-consumer-all/liquidnet-service-consumer-kylin/src/main/java/com/liquidnet/service/consumer/kylin/receiver/ConsumerOrderClose5RdsReceiver.java

@@ -4,7 +4,7 @@ import com.liquidnet.service.base.constant.MQConst;
 import org.springframework.stereotype.Component;
 
 @Component
-public class ConsumerOrderClose5RdsReceiver extends AbstractSqlRedisReceiver {
+public class ConsumerOrderClose5RdsReceiver extends AbstractOrderCloseReceiver {
     @Override
     protected String getRedisStreamKey() {
         return MQConst.GoblinQueue.GOBLIN_UN_PAY_5.getKey();

liquidnet-bus-service/liquidnet-service-consumer-all/liquidnet-service-consumer-kylin/src/main/java/com/liquidnet/service/consumer/kylin/receiver/ConsumerOrderClose6RdsReceiver.java

@@ -4,7 +4,7 @@ import com.liquidnet.service.base.constant.MQConst;
 import org.springframework.stereotype.Component;
 
 @Component
-public class ConsumerOrderClose6RdsReceiver extends AbstractSqlRedisReceiver {
+public class ConsumerOrderClose6RdsReceiver extends AbstractOrderCloseReceiver {
     @Override
     protected String getRedisStreamKey() {
         return MQConst.GoblinQueue.GOBLIN_UN_PAY_6.getKey();

liquidnet-bus-service/liquidnet-service-consumer-all/liquidnet-service-consumer-kylin/src/main/java/com/liquidnet/service/consumer/kylin/receiver/ConsumerOrderClose7RdsReceiver.java

@@ -4,7 +4,7 @@ import com.liquidnet.service.base.constant.MQConst;
 import org.springframework.stereotype.Component;
 
 @Component
-public class ConsumerOrderClose7RdsReceiver extends AbstractSqlRedisReceiver {
+public class ConsumerOrderClose7RdsReceiver extends AbstractOrderCloseReceiver {
     @Override
     protected String getRedisStreamKey() {
         return MQConst.GoblinQueue.GOBLIN_UN_PAY_7.getKey();

liquidnet-bus-service/liquidnet-service-consumer-all/liquidnet-service-consumer-kylin/src/main/java/com/liquidnet/service/consumer/kylin/receiver/ConsumerOrderClose8RdsReceiver.java

@@ -4,7 +4,7 @@ import com.liquidnet.service.base.constant.MQConst;
 import org.springframework.stereotype.Component;
 
 @Component
-public class ConsumerOrderClose8RdsReceiver extends AbstractSqlRedisReceiver {
+public class ConsumerOrderClose8RdsReceiver extends AbstractOrderCloseReceiver {
     @Override
     protected String getRedisStreamKey() {
         return MQConst.GoblinQueue.GOBLIN_UN_PAY_8.getKey();

liquidnet-bus-service/liquidnet-service-consumer-all/liquidnet-service-consumer-kylin/src/main/java/com/liquidnet/service/consumer/kylin/receiver/ConsumerOrderClose9RdsReceiver.java

@@ -4,7 +4,7 @@ import com.liquidnet.service.base.constant.MQConst;
 import org.springframework.stereotype.Component;
 
 @Component
-public class ConsumerOrderClose9RdsReceiver extends AbstractSqlRedisReceiver {
+public class ConsumerOrderClose9RdsReceiver extends AbstractOrderCloseReceiver {
     @Override
     protected String getRedisStreamKey() {
         return MQConst.GoblinQueue.GOBLIN_UN_PAY_9.getKey();