mq 相关配置去除，启动配置修改

zhongrj

2022-08-18 38d775fa2ccd433c727a5b7cec8bed02493df1ec

 src/main/java/org/springblade/modules/rabbitmq/config/MQreceiver.java

@@ -1,34 +1,34 @@
package org.springblade.modules.rabbitmq.config;

import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springblade.modules.rabbitmq.redis.RedisService;
import org.springblade.modules.rabbitmq.vo.TaskMessage;
import org.springframework.amqp.rabbit.annotation.RabbitListener;
import org.springframework.data.redis.core.script.RedisScript;
import org.springframework.stereotype.Service;

/**
 * 队列消息接收
 * @author zhongrj
 * @since 2022-04-12
 */
@Service
public class MQreceiver {


    private static Logger log = LoggerFactory.getLogger(MQreceiver.class);


    @RabbitListener(queues = MQConfig.TASK_QUEUE)
    public void receive(String message){

        log.info("receive message:"+message);


      TaskMessage taskMessage = RedisService.stringToBean(message, TaskMessage.class);

      System.out.println("用户" + taskMessage.getManId() + "抢到了任务："+ taskMessage.getTaskId());

   }
}
//package org.springblade.modules.rabbitmq.config;
//
//import org.slf4j.Logger;
//import org.slf4j.LoggerFactory;
//import org.springblade.modules.rabbitmq.redis.RedisService;
//import org.springblade.modules.rabbitmq.vo.TaskMessage;
//import org.springframework.amqp.rabbit.annotation.RabbitListener;
//import org.springframework.data.redis.core.script.RedisScript;
//import org.springframework.stereotype.Service;
//
///**
// * 队列消息接收
// * @author zhongrj
// * @since 2022-04-12
// */
//@Service
//public class MQreceiver {
//
//
//    private static Logger log = LoggerFactory.getLogger(MQreceiver.class);
//
//
//    @RabbitListener(queues = MQConfig.TASK_QUEUE)
//    public void receive(String message){
//
//        log.info("receive message:"+message);
//
//
//      TaskMessage taskMessage = RedisService.stringToBean(message, TaskMessage.class);
//
//      System.out.println("用户" + taskMessage.getManId() + "抢到了任务："+ taskMessage.getTaskId());
//
//   }
//}