!119 优化consumer延时任务执行器(修复一个高版本的redis可能导致redis连接不上问题)
Merge pull request !119 from OceansDeep/feature/pg
This commit is contained in:
commit
27397f1602
@ -5,10 +5,10 @@ import cn.lili.cache.Cache;
|
||||
import cn.lili.common.utils.ThreadPoolUtil;
|
||||
import lombok.extern.slf4j.Slf4j;
|
||||
import org.springframework.beans.factory.annotation.Autowired;
|
||||
import org.springframework.boot.ApplicationRunner;
|
||||
import org.springframework.data.redis.core.DefaultTypedTuple;
|
||||
import org.springframework.util.CollectionUtils;
|
||||
|
||||
import javax.annotation.PostConstruct;
|
||||
import java.util.Set;
|
||||
import java.util.concurrent.TimeUnit;
|
||||
|
||||
@ -19,7 +19,7 @@ import java.util.concurrent.TimeUnit;
|
||||
* @since 2020/11/7
|
||||
**/
|
||||
@Slf4j
|
||||
public abstract class AbstractDelayQueueListen {
|
||||
public abstract class AbstractDelayQueueListen implements ApplicationRunner {
|
||||
|
||||
@Autowired
|
||||
private Cache cache;
|
||||
@ -87,7 +87,6 @@ public abstract class AbstractDelayQueueListen {
|
||||
/**
|
||||
* 监听队列
|
||||
*/
|
||||
@PostConstruct
|
||||
public void init() {
|
||||
ThreadPoolUtil.getPool().execute(this::startDelayQueueMachine);
|
||||
}
|
||||
|
@ -1,11 +1,12 @@
|
||||
package cn.lili.trigger.listen;
|
||||
|
||||
import cn.hutool.json.JSONUtil;
|
||||
import cn.lili.trigger.AbstractDelayQueueListen;
|
||||
import cn.lili.trigger.enums.DelayQueueEnums;
|
||||
import cn.lili.trigger.interfaces.TimeTrigger;
|
||||
import cn.lili.trigger.model.TimeTriggerMsg;
|
||||
import cn.lili.trigger.AbstractDelayQueueListen;
|
||||
import org.springframework.beans.factory.annotation.Autowired;
|
||||
import org.springframework.boot.ApplicationArguments;
|
||||
import org.springframework.stereotype.Component;
|
||||
|
||||
/**
|
||||
@ -31,4 +32,9 @@ public class PromotionDelayQueueListen extends AbstractDelayQueueListen {
|
||||
public String setDelayQueueName() {
|
||||
return DelayQueueEnums.PROMOTION.name();
|
||||
}
|
||||
|
||||
@Override
|
||||
public void run(ApplicationArguments args) throws Exception {
|
||||
this.init();
|
||||
}
|
||||
}
|
||||
|
Loading…
x
Reference in New Issue
Block a user