记得上下班打卡 | git大法好，push需谨慎

Skip to content

L
liquidnet-bus-v1
Commit 7945786a authored by zhanggb's avatar zhanggb
Browse files
Options

~queue:opt;

parent 7bcfee46
Show whitespace changes
Inline Side-by-side
Showing with 51 additions and 51 deletions
liquidnet-bus-service/liquidnet-service-consumer-all/liquidnet-service-consumer-kylin/src/main/java/com/liquidnet/service/consumer/kylin/receiver/ConsumerGoblinSqlCouponRdsReceiver.java
View file @ 7945786a
package com.liquidnet.service.consumer.kylin.receiver;
import com.liquidnet.service.base.constant.MQConst;
import org.springframework.stereotype.Component;
@Component
public class ConsumerGoblinSqlCouponRdsReceiver extends AbstractSqlRedisReceiver {
@Override
protected String getRedisStreamKey() {
return MQConst.GoblinQueue.SQL_COUPON.getKey();
}
@Override
protected String getRedisStreamGroup() {
return MQConst.GoblinQueue.SQL_COUPON.getGroup();
}
}
//package com.liquidnet.service.consumer.kylin.receiver;
//
//import com.liquidnet.service.base.constant.MQConst;
//import org.springframework.stereotype.Component;
//
//@Component
//public class ConsumerGoblinSqlCouponRdsReceiver extends AbstractSqlRedisReceiver {
// @Override
// protected String getRedisStreamKey() {
// return MQConst.GoblinQueue.SQL_COUPON.getKey();
// }
//
// @Override
// protected String getRedisStreamGroup() {
// return MQConst.GoblinQueue.SQL_COUPON.getGroup();
// }
//}
liquidnet-bus-service/liquidnet-service-consumer-all/liquidnet-service-consumer-kylin/src/main/java/com/liquidnet/service/consumer/kylin/receiver/ConsumerGoblinSqlGoodsRdsReceiver.java
View file @ 7945786a
package com.liquidnet.service.consumer.kylin.receiver;
import com.liquidnet.service.base.constant.MQConst;
import org.springframework.stereotype.Component;
@Component
public class ConsumerGoblinSqlGoodsRdsReceiver extends AbstractSqlRedisReceiver {
@Override
protected String getRedisStreamKey() {
return MQConst.GoblinQueue.SQL_GOODS.getKey();
}
@Override
protected String getRedisStreamGroup() {
return MQConst.GoblinQueue.SQL_GOODS.getGroup();
}
}
//package com.liquidnet.service.consumer.kylin.receiver;
//
//import com.liquidnet.service.base.constant.MQConst;
//import org.springframework.stereotype.Component;
//
//@Component
//public class ConsumerGoblinSqlGoodsRdsReceiver extends AbstractSqlRedisReceiver {
// @Override
// protected String getRedisStreamKey() {
// return MQConst.GoblinQueue.SQL_GOODS.getKey();
// }
//
// @Override
// protected String getRedisStreamGroup() {
// return MQConst.GoblinQueue.SQL_GOODS.getGroup();
// }
//}
liquidnet-bus-service/liquidnet-service-consumer-all/liquidnet-service-consumer-kylin/src/main/java/com/liquidnet/service/consumer/kylin/receiver/ConsumerGoblinSqlStoreRdsReceiver.java
View file @ 7945786a
package com.liquidnet.service.consumer.kylin.receiver;
import com.liquidnet.service.base.constant.MQConst;
import org.springframework.stereotype.Component;
@Component
public class ConsumerGoblinSqlStoreRdsReceiver extends AbstractSqlRedisReceiver {
@Override
protected String getRedisStreamKey() {
return MQConst.GoblinQueue.SQL_STORE.getKey();
}
@Override
protected String getRedisStreamGroup() {
return MQConst.GoblinQueue.SQL_STORE.getGroup();
}
}
//package com.liquidnet.service.consumer.kylin.receiver;
//
//import com.liquidnet.service.base.constant.MQConst;
//import org.springframework.stereotype.Component;
//
//@Component
//public class ConsumerGoblinSqlStoreRdsReceiver extends AbstractSqlRedisReceiver {
// @Override
// protected String getRedisStreamKey() {
// return MQConst.GoblinQueue.SQL_STORE.getKey();
// }
//
// @Override
// protected String getRedisStreamGroup() {
// return MQConst.GoblinQueue.SQL_STORE.getGroup();
// }
//}
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment