|
@@ -102,8 +102,8 @@ public class RabbitMqListener {
|
|
|
String msg = new String(message.getBody(), StandardCharsets.UTF_8);
|
|
|
log.info("发送钉钉消息处理,队列名:{},id:{},消息体:{}", queueModelingDt, correlationId, msg);
|
|
|
BuildSceneFailDTMqMessage dtMessage = JSONObject.parseObject(msg, BuildSceneFailDTMqMessage.class);
|
|
|
- buildSceneDTService.handFail(dtMessage.getReason(), dtMessage.getServerPath(),
|
|
|
- dtMessage.getNum(), dtMessage.getHostName(), DingTalkConst.contentExt);
|
|
|
+// buildSceneDTService.handFail(dtMessage.getReason(), dtMessage.getServerPath(),
|
|
|
+// dtMessage.getNum(), dtMessage.getHostName(), DingTalkConst.contentExt);
|
|
|
channel.basicAck(message.getMessageProperties().getDeliveryTag(), false);
|
|
|
}
|
|
|
|