From 187840576b49fc6810267a98d418ea56fe26eee8 Mon Sep 17 00:00:00 2001 From: tianwenbo Date: Fri, 10 Mar 2023 09:17:13 +0800 Subject: [PATCH] =?UTF-8?q?=E3=80=90fix=20sonar=E3=80=91=20RabbitMqConfig.?= =?UTF-8?q?java=E6=96=87=E4=BB=B6?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../boot/starter/rabbitmq/config/RabbitMqConfig.java | 10 +++++----- 1 file changed, 5 insertions(+), 5 deletions(-) diff --git a/jero-boot/jero-boot-starter/jero-boot-starter-rabbitmq/src/main/java/com/jero/boot/starter/rabbitmq/config/RabbitMqConfig.java b/jero-boot/jero-boot-starter/jero-boot-starter-rabbitmq/src/main/java/com/jero/boot/starter/rabbitmq/config/RabbitMqConfig.java index ff3233a1..ad54f6c5 100644 --- a/jero-boot/jero-boot-starter/jero-boot-starter-rabbitmq/src/main/java/com/jero/boot/starter/rabbitmq/config/RabbitMqConfig.java +++ b/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; }