|
@@ -1,6 +1,7 @@
|
|
package com.fdkanfang.web.mq.listener;
|
|
package com.fdkanfang.web.mq.listener;
|
|
|
|
|
|
import cn.hutool.core.io.FileUtil;
|
|
import cn.hutool.core.io.FileUtil;
|
|
|
|
+import com.alibaba.fastjson.JSON;
|
|
import com.fdkanfang.common.constant.MsgCode;
|
|
import com.fdkanfang.common.constant.MsgCode;
|
|
import com.fdkanfang.common.enums.ResultCodeEnum;
|
|
import com.fdkanfang.common.enums.ResultCodeEnum;
|
|
import com.fdkanfang.common.exception.BaseRuntimeException;
|
|
import com.fdkanfang.common.exception.BaseRuntimeException;
|
|
@@ -29,7 +30,7 @@ import java.util.HashMap;
|
|
@Log4j2
|
|
@Log4j2
|
|
@Component
|
|
@Component
|
|
//@RabbitListener(queues = RabbitConfig.VERTICAL_QUEUE) // 指定监听队列
|
|
//@RabbitListener(queues = RabbitConfig.VERTICAL_QUEUE) // 指定监听队列
|
|
-@RabbitListener(queues = "${verticle.queue}") // 指定监听队列
|
|
|
|
|
|
+
|
|
public class VerticalListener {
|
|
public class VerticalListener {
|
|
|
|
|
|
@Autowired
|
|
@Autowired
|
|
@@ -40,10 +41,12 @@ public class VerticalListener {
|
|
/**
|
|
/**
|
|
* order结果监听
|
|
* order结果监听
|
|
*/
|
|
*/
|
|
- @RabbitHandler
|
|
|
|
// @Transactional(rollbackFor = Exception.class)
|
|
// @Transactional(rollbackFor = Exception.class)
|
|
|
|
+ @RabbitHandler
|
|
|
|
+ @RabbitListener(queues = "${verticle.queue}") // 指定监听队列
|
|
public void getMessage(HashMap<Object, Object> mqMap){
|
|
public void getMessage(HashMap<Object, Object> mqMap){
|
|
log.info("===================收到MQ消息,开始执行垂直校验===================== ");
|
|
log.info("===================收到MQ消息,开始执行垂直校验===================== ");
|
|
|
|
+ log.info("接收到的mq请求参数:{}" , JSON.toJSONString(mqMap));
|
|
Long houseId = (Long)mqMap.get("id");
|
|
Long houseId = (Long)mqMap.get("id");
|
|
String basePath = (String)mqMap.get("basePath");
|
|
String basePath = (String)mqMap.get("basePath");
|
|
|
|
|