异常日志前端展示添加

log-manager/src/main/java/com/mortals/xhx/base/framework/config/RabbitConfig.java

@@ -99,7 +99,7 @@ public class RabbitConfig {
         configurer.configure(factory, connectionFactory);
         // 额外添加批量消费的属性
         factory.setBatchListener(true);
-        factory.setBatchSize(10);
+        factory.setBatchSize(5);
         factory.setReceiveTimeout(5 * 1000L);
         factory.setConsumerBatchEnabled(true);
         return factory;
@@ -112,7 +112,7 @@ public class RabbitConfig {
     }
 
 
-    @Bean
+   // @Bean
     public AsyncRabbitTemplate asyncRabbitTemplate(RabbitTemplate rabbitTemplate) {
         AsyncRabbitTemplate asyncRabbitTemplate = new AsyncRabbitTemplate(rabbitTemplate);
         asyncRabbitTemplate.setReceiveTimeout(10000);

log-manager/src/main/java/com/mortals/xhx/base/framework/listener/AccessMessageConsumerListener.java

@@ -60,7 +60,6 @@ public class AccessMessageConsumerListener {
         List<AccessLogEntity> collect = messages.stream().map(message -> {
             try {
                 //String json = JSONUtil.formatJsonStr(new String(message, StandardCharsets.UTF_8));
-
                 AccessLogEntity entity = JSON.parseObject(message, AccessLogEntity.class);
                 entity.setId(IdUtil.getSnowflake(0, 1).nextId());
                 entity.setCreateUserId(1L);