【fix sonar】 RabbitMqConfig.java文件

jero-boot/jero-boot-starter/jero-boot-starter-rabbitmq/src/main/java/com/jero/boot/starter/rabbitmq/config/RabbitMqConfig.java

@@ -1,18 +1,17 @@
 package com.jero.boot.starter.rabbitmq.config;
 
-import java.util.UUID;
-
 import com.jero.boot.starter.rabbitmq.event.JeroRemoteApplicationEvent;
 import com.jero.common.config.mqtoken.TransmitUserTokenFilter;
 import org.springframework.amqp.core.AcknowledgeMode;
 import org.springframework.amqp.rabbit.connection.ConnectionFactory;
 import org.springframework.amqp.rabbit.core.RabbitAdmin;
 import org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer;
-import org.springframework.amqp.support.ConsumerTagStrategy;
 import org.springframework.cloud.bus.jackson.RemoteApplicationEventScan;
 import org.springframework.context.annotation.Bean;
 import org.springframework.context.annotation.Configuration;
 
+import java.util.UUID;
+
 /**
  * 消息队列配置类
  *
@@ -54,12 +53,13 @@ public class RabbitMqConfig {
         container.setDefaultRequeueRejected(true);
 
         //消费端的标签策略
-        container.setConsumerTagStrategy(new ConsumerTagStrategy() {
+        /*container.setConsumerTagStrategy(new ConsumerTagStrategy() {
             @Override
             public String createConsumerTag(String queue) {
                 return queue + "_" + UUID.randomUUID().toString();
             }
-        });
+        });*/
+        container.setConsumerTagStrategy(queue-> queue + "_" + UUID.randomUUID());
         return container;
     }