业务日志添加

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

@@ -111,6 +111,21 @@ public class RabbitConfig {
         return factory;
     }
 
+    @Bean(name = "consumerContainerFactory")
+    public SimpleRabbitListenerContainerFactory consumerContainerFactory(
+            SimpleRabbitListenerContainerFactoryConfigurer configurer, ConnectionFactory connectionFactory) {
+        // 创建 SimpleRabbitListenerContainerFactory 对象
+        SimpleRabbitListenerContainerFactory factory = new SimpleRabbitListenerContainerFactory();
+
+        factory.setAfterReceivePostProcessors(m -> {
+            m.getMessageProperties().setContentType("application/json");
+            return m;
+        });
+
+        configurer.configure(factory, connectionFactory);
+        return factory;
+    }
+
     //修改系列和与反序列化转换器
     @Bean
     public MessageConverter messageConverter() {

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

@@ -34,7 +34,7 @@ import java.util.stream.Collectors;
  **/
 @Slf4j
 @Component
-@RabbitListener(queues = QueueKey.OPERATION_LOG_QUEUE)
+@RabbitListener(queues = QueueKey.OPERATION_LOG_QUEUE,containerFactory = "consumerContainerFactory")
 //@RabbitListener(queues = QueueKey.OPERATION_LOG_QUEUE,
 //        containerFactory = "consumerBatchContainerFactory")
 public class OperateMessageConsumerListener {