diff --git a/ai-analytic-center-biz/pom.xml b/ai-analytic-center-biz/pom.xml index adfa607..d26082a 100644 --- a/ai-analytic-center-biz/pom.xml +++ b/ai-analytic-center-biz/pom.xml @@ -126,11 +126,17 @@ xxl-job-core 2.3.0 - + + + ru.yandex.clickhouse + clickhouse-jdbc + 0.1.53 + diff --git a/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/service/impl/MqMessageRecordServiceImpl.java b/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/service/impl/MqMessageRecordServiceImpl.java index 0d5ed89..faee731 100644 --- a/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/service/impl/MqMessageRecordServiceImpl.java +++ b/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/service/impl/MqMessageRecordServiceImpl.java @@ -35,8 +35,8 @@ import java.util.stream.Collectors; @Service public class MqMessageRecordServiceImpl extends ServiceImpl implements MqMessageRecordService { - @Autowired - private AmqpTemplate rabbitTemplate; +// @Autowired +// private AmqpTemplate rabbitTemplate; @Autowired private DataMaskingRuleService dataMaskingRuleService; @@ -462,7 +462,7 @@ public class MqMessageRecordServiceImpl extends ServiceImpl