This commit is contained in:
YAS\29473
2026-01-09 17:28:39 +08:00
parent 86c90b9d36
commit bf9544bcdc

View File

@@ -386,7 +386,7 @@ public class UploadRealTimeMonitorHandler extends AbstractYkcHandler {
// 向mq中发送实时数据消息,给第三方服务消费 // 向mq中发送实时数据消息,给第三方服务消费
CompletableFuture.runAsync(() -> { CompletableFuture.runAsync(() -> {
try { try {
log.info("向mq中发送实时数据消息供第三方服务消费, realTimeMonitorData:{}", realTimeMonitorData); log.debug("向mq中发送实时数据消息供第三方服务消费, realTimeMonitorData:{}", realTimeMonitorData);
rabbitTemplate.convertAndSend(ThirdPartyRabbitConstants.WCC_THIRDPARTY_NAME,ThirdPartyRabbitConstants.ROUTING_KEY_REALTIME_DATA_PUSH, realTimeMonitorData); rabbitTemplate.convertAndSend(ThirdPartyRabbitConstants.WCC_THIRDPARTY_NAME,ThirdPartyRabbitConstants.ROUTING_KEY_REALTIME_DATA_PUSH, realTimeMonitorData);
} catch (Exception e){ } catch (Exception e){
log.error("向mq中发送实时数据消息供第三方服务消费 error, ", e); log.error("向mq中发送实时数据消息供第三方服务消费 error, ", e);