package com.ks.vip.job;
|
|
//import com.ks.lijin.service.LuckyMQService;
|
import org.springframework.stereotype.Component;
|
|
@Component
|
public class MQJob {
|
|
// @Resource
|
// private LuckyMQService luckyMQService;
|
|
|
// @XxlJob("mqjob-sendmq")
|
// public ReturnT<String> sendMQ(String param) throws Exception {
|
// Date now = new Date();
|
// List<LuckyMQ> mqList = luckyMQService.listUnSendMsg(now, 1, 1000);
|
// if (mqList != null) {
|
// for (LuckyMQ mq : mqList) {
|
// luckyMQService.sendMsg(mq.getTaskId());
|
// }
|
// }
|
// return ReturnT.SUCCESS;
|
// }
|
|
|
}
|