| | |
|---|
| | | import org.springframework.beans.factory.annotation.Autowired; |
|---|
| | | import org.springframework.stereotype.Component; |
|---|
| | | |
|---|
| | | /** |
|---|
| | | * 利用rockmq，从日志中心接受日志信息存入本地库tdengine中 |
|---|
| | | */ |
|---|
| | | @RocketMQMessageListener(consumerGroup = DmpLogSyncConstant.CONSUMER_GROUP, topic = DmpLogSyncConstant.DMP_LOG_TOPIC) |
|---|
| | | @Component |
|---|
| | | /* loaded from: blade-api.jar:BOOT-INF/classes/org/springblade/modules/dmpLog/message/consumer/DmpLogSyncConsumer.class */ |
|---|
| | | public class DmpLogSyncConsumer implements RocketMQListener<DmpLogMessage>, RocketMQPushConsumerLifecycleListener { |
|---|
| | | private DateTimeFormatter fmt = DateTimeFormatter.ofPattern("yyyyMM"); |
|---|
| | | @Autowired |
|---|
| | |
|---|
| | | public void onMessage(DmpLogMessage dmpLogMessage) { |
|---|
| | | JSONObject jsonObject = dmpLogMessage.getMessage(); |
|---|
| | | if (Func.isNotEmpty(jsonObject)) { |
|---|
| | | jsonObject.getInteger("Type"); |
|---|
| | | Integer msgType = jsonObject.getInteger("Type"); |
|---|
| | | try { |
|---|
| | | switch ((LogTypeEnum) Objects.requireNonNull(LogTypeEnum.getValue(msgType))) { |
|---|
| | | case Signal: |
|---|
