From f681b70088fc0a456ceaf95c8f02f297f7821b5c Mon Sep 17 00:00:00 2001 From: tianwenbo Date: Fri, 10 Mar 2023 09:12:24 +0800 Subject: [PATCH] =?UTF-8?q?=E3=80=90fix=20sonar=E3=80=91=20RabbitMqClient.?= =?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/client/RabbitMqClient.java | 11 ++++------- 1 file changed, 4 insertions(+), 7 deletions(-) diff --git a/jero-boot/jero-boot-starter/jero-boot-starter-rabbitmq/src/main/java/com/jero/boot/starter/rabbitmq/client/RabbitMqClient.java b/jero-boot/jero-boot-starter/jero-boot-starter-rabbitmq/src/main/java/com/jero/boot/starter/rabbitmq/client/RabbitMqClient.java index 17a0ecec..fb7932ee 100644 --- a/jero-boot/jero-boot-starter/jero-boot-starter-rabbitmq/src/main/java/com/jero/boot/starter/rabbitmq/client/RabbitMqClient.java +++ b/jero-boot/jero-boot-starter/jero-boot-starter-rabbitmq/src/main/java/com/jero/boot/starter/rabbitmq/client/RabbitMqClient.java @@ -140,8 +140,7 @@ public class RabbitMqClient { public Message getMessage(String messageType, Object msg) { MessageProperties messageProperties = new MessageProperties(); messageProperties.setContentType(messageType); - Message message = new Message(msg.toString().getBytes(), messageProperties); - return message; + return new Message(msg.toString().getBytes(), messageProperties); } /** @@ -163,7 +162,7 @@ public class RabbitMqClient { */ public void sendMessageToExchange(TopicExchange topicExchange, AbstractExchange exchange, String msg) { addExchange(exchange); - logger.info("RabbitMQ send " + exchange.getName() + "->" + msg); + log.info("RabbitMQ send " + exchange.getName() + "->" + msg); rabbitTemplate.convertAndSend(topicExchange.getName(), msg); } @@ -177,9 +176,7 @@ public class RabbitMqClient { public void sendMessage(String queueName, Object params) { log.info("发送消息到mq"); try { - rabbitTemplate.convertAndSend(DelayExchangeBuilder.DELAY_EXCHANGE, queueName, params, message -> { - return message; - }); + rabbitTemplate.convertAndSend(DelayExchangeBuilder.DELAY_EXCHANGE, queueName, params, message -> message); } catch (Exception e) { e.printStackTrace(); } @@ -261,7 +258,7 @@ public class RabbitMqClient { Binding binding = BindingBuilder.bind(queue).to(directExchange).withQueueName(); rabbitAdmin.declareBinding(binding); String messages = (String) rabbitTemplate.receiveAndConvert(queueName); - System.out.println("Receive:" + messages); + log.info("Receive:" + messages); return messages; }