package com.highdatas.mdm.util;

import lombok.extern.slf4j.Slf4j;
import org.springframework.context.annotation.Configuration;
import org.springframework.scheduling.annotation.EnableScheduling;

/**
 * @author kimi
 * @description
 * @date 2020-04-15 13:25
 */


@Configuration
@EnableScheduling
@Slf4j
public class TimeTasks {
//    @Autowired
//    DispenseService dispenseService;

//    @Scheduled(fixedRate=1000 * 10)
//    private void configureTasks() {
//        PriorityBlockingQueue<Runnable> queue = dispenseService.getQueue();
//        if (queue.isEmpty()) {
//            return;
//        }
//        log.info("queue passiveQueueSize: {}", queue.size());
//        for (Runnable runnable : queue) {
//            if (!(runnable instanceof MqMessage)) {
//                continue;
//            }
//            MqMessage mqMessage = (MqMessage) runnable;
//            Date endTime = mqMessage.getEndTime();
//            Date now = new Date();
//            if (now.after(endTime)) {
//                //timeout;
//                try {
//                    mqMessage.printTimeOut();
//                } catch (IOException e) {
//                    e.printStackTrace();
//                }
//            }
//        }
//    }
}