Merge remote-tracking branch 'origin/hjc' into hjc

liquidnet-bus-service/liquidnet-service-consumer-all/liquidnet-service-consumer-kylin/src/main/java/com/liquidnet/service/consumer/kylin/receiver/AbstractGoblinOrderCloseReceiver.java → liquidnet-bus-service/liquidnet-service-consumer-all/liquidnet-service-consumer-kylin/src/main/java/com/liquidnet/service/consumer/kylin/receiver/AbstractOrderCloseReceiver.java

@@ -27,7 +27,7 @@ import java.util.HashMap;
 import java.util.LinkedList;
 
 @Slf4j
-public abstract class AbstractGoblinOrderCloseReceiver implements StreamListener<String, MapRecord<String, String, String>> {
+public abstract class AbstractOrderCloseReceiver implements StreamListener<String, MapRecord<String, String, String>> {
     @Autowired
     StringRedisTemplate stringRedisTemplate;
     @Autowired

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

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

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();