package com.moral.monitor.listener; import org.slf4j.Logger; import org.slf4j.LoggerFactory; import org.springframework.amqp.core.Message; import org.springframework.amqp.core.MessageListener; import org.springframework.amqp.rabbit.core.RabbitTemplate; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Component; import com.moral.monitor.dao.TaskDao; /*不报警版本*/ @Component public class Listener implements MessageListener { @Autowired RabbitTemplate rabbitTemplate; // @Autowired // Lo private Logger logger = LoggerFactory.getLogger(Listener.class); public void onMessage(Message message) { logger.warn("正在运行的线程名称=" + Thread.currentThread().getName()); } }