caojiahao/dev_caojiahao
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Merge branch 'master' of gitee.com:beijing_hongye_huicheng/lilishop

Browse Source
This commit is contained in:
Chopper 2022-01-21 12:08:40 +08:00
commit cb0a9121e5
2 changed files with 9 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
consumer/src/main/java/cn/lili/trigger/AbstractDelayQueueListen.java
View File

@ -5,10 +5,10 @@ import cn.lili.cache.Cache;
import cn.lili.common.utils.ThreadPoolUtil; import cn.lili.common.utils.ThreadPoolUtil;
import lombok.extern.slf4j.Slf4j; import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired; import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.ApplicationRunner;
import org.springframework.data.redis.core.DefaultTypedTuple; import org.springframework.data.redis.core.DefaultTypedTuple;
import org.springframework.util.CollectionUtils; import org.springframework.util.CollectionUtils;
import javax.annotation.PostConstruct;
import java.util.Set; import java.util.Set;
import java.util.concurrent.TimeUnit; import java.util.concurrent.TimeUnit;
@ -19,7 +19,7 @@ import java.util.concurrent.TimeUnit;
* @since 2020/11/7 * @since 2020/11/7
**/ **/
@Slf4j @Slf4j
public abstract class AbstractDelayQueueListen { public abstract class AbstractDelayQueueListen implements ApplicationRunner {
@Autowired @Autowired
private Cache cache; private Cache cache;
@ -87,7 +87,6 @@ public abstract class AbstractDelayQueueListen {
/** /**
* 监听队列 * 监听队列
*/ */
@PostConstruct
public void init() { public void init() {
ThreadPoolUtil.getPool().execute(this::startDelayQueueMachine); ThreadPoolUtil.getPool().execute(this::startDelayQueueMachine);
} }

8
consumer/src/main/java/cn/lili/trigger/listen/PromotionDelayQueueListen.java
View File

@ -1,11 +1,12 @@
package cn.lili.trigger.listen; package cn.lili.trigger.listen;
import cn.hutool.json.JSONUtil; import cn.hutool.json.JSONUtil;
import cn.lili.trigger.AbstractDelayQueueListen;
import cn.lili.trigger.enums.DelayQueueEnums; import cn.lili.trigger.enums.DelayQueueEnums;
import cn.lili.trigger.interfaces.TimeTrigger; import cn.lili.trigger.interfaces.TimeTrigger;
import cn.lili.trigger.model.TimeTriggerMsg; import cn.lili.trigger.model.TimeTriggerMsg;
import cn.lili.trigger.AbstractDelayQueueListen;
import org.springframework.beans.factory.annotation.Autowired; import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.ApplicationArguments;
import org.springframework.stereotype.Component; import org.springframework.stereotype.Component;
/** /**
@ -31,4 +32,9 @@ public class PromotionDelayQueueListen extends AbstractDelayQueueListen {
public String setDelayQueueName() { public String setDelayQueueName() {
return DelayQueueEnums.PROMOTION.name(); return DelayQueueEnums.PROMOTION.name();
} }
@Override
public void run(ApplicationArguments args) throws Exception {
this.init();
}
} }