JeroBoot/base
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

【fix sonar】 RabbitMqClient.java文件

Browse Source
This commit is contained in:
tianwenbo
2023-03-10 09:12:24 +08:00
parent b1a8ecc6a4
commit f681b70088
1 changed files with 4 additions and 7 deletions
Download Patch File Download Diff File Expand all files Collapse all files
jero-boot/jero-boot-starter/jero-boot-starter-rabbitmq/src/main/java/com/jero/boot/starter/rabbitmq/client/RabbitMqClient.java
+4 -7
View File
@@ -140,8 +140,7 @@ public class RabbitMqClient {
public Message getMessage(String messageType, Object msg) { public Message getMessage(String messageType, Object msg) {
MessageProperties messageProperties = new MessageProperties(); MessageProperties messageProperties = new MessageProperties();
messageProperties.setContentType(messageType); messageProperties.setContentType(messageType);
Message message = new Message(msg.toString().getBytes(), messageProperties); return new Message(msg.toString().getBytes(), messageProperties);
return message;
} }
/** /**
@@ -163,7 +162,7 @@ public class RabbitMqClient {
*/ */
public void sendMessageToExchange(TopicExchange topicExchange, AbstractExchange exchange, String msg) { public void sendMessageToExchange(TopicExchange topicExchange, AbstractExchange exchange, String msg) {
addExchange(exchange); addExchange(exchange);
logger.info("RabbitMQ send " + exchange.getName() + "->" + msg); log.info("RabbitMQ send " + exchange.getName() + "->" + msg);
rabbitTemplate.convertAndSend(topicExchange.getName(), msg); rabbitTemplate.convertAndSend(topicExchange.getName(), msg);
} }
@@ -177,9 +176,7 @@ public class RabbitMqClient {
public void sendMessage(String queueName, Object params) { public void sendMessage(String queueName, Object params) {
log.info("发送消息到mq"); log.info("发送消息到mq");
try { try {
rabbitTemplate.convertAndSend(DelayExchangeBuilder.DELAY_EXCHANGE, queueName, params, message -> { rabbitTemplate.convertAndSend(DelayExchangeBuilder.DELAY_EXCHANGE, queueName, params, message -> message);
return message;
});
} catch (Exception e) { } catch (Exception e) {
e.printStackTrace(); e.printStackTrace();
} }
@@ -261,7 +258,7 @@ public class RabbitMqClient {
Binding binding = BindingBuilder.bind(queue).to(directExchange).withQueueName(); Binding binding = BindingBuilder.bind(queue).to(directExchange).withQueueName();
rabbitAdmin.declareBinding(binding); rabbitAdmin.declareBinding(binding);
String messages = (String) rabbitTemplate.receiveAndConvert(queueName); String messages = (String) rabbitTemplate.receiveAndConvert(queueName);
System.out.println("Receive:" + messages); log.info("Receive:" + messages);
return messages; return messages;
} }