代码提交

patient-co-analysis/src/main/java/com/yihu/wlyy/analysis/scheduler/LabelDataScheduler.java

@@ -1,4 +1,4 @@
package com.yihu.wlyy.analysis.scheduler;
package com.yihu.wlyy.analysis.listener;
import org.apache.kafka.clients.consumer.ConsumerRecord;
import org.slf4j.Logger;
@@ -13,7 +13,7 @@ import java.util.Optional;
 * Created by Administrator on 2017/2/6.
 */
@Component
public class LabelDataScheduler {
public class LabelDataListener {
    private final Logger logger = LoggerFactory.getLogger(this.getClass());
    //@Scheduled(cron = "0 0/1 * * * ?") //每分钟执行一次