~queue.consumer.handler;

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