From 8b375fe00a241b3a769b82fe3dac8d1c9dce8a02 Mon Sep 17 00:00:00 2001
From: Administrator <admin>
Date: Thu, 16 Jun 2022 14:36:07 +0800
Subject: [PATCH] 模拟考试修改
---
src/main/java/org/springblade/modules/rabbitmq/config/MQreceiver.java | 68 +++++++++++++++++-----------------
1 files changed, 34 insertions(+), 34 deletions(-)
diff --git a/src/main/java/org/springblade/modules/rabbitmq/config/MQreceiver.java b/src/main/java/org/springblade/modules/rabbitmq/config/MQreceiver.java
index c1a07d0..8134d56 100644
--- a/src/main/java/org/springblade/modules/rabbitmq/config/MQreceiver.java
+++ b/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());
+//
+// }
+//}
--
Gitblit v1.9.3