From 26b41e388291db4c70cf04d10763d13423045813 Mon Sep 17 00:00:00 2001
From: zhangdaiscott <zhangdaiscott@163.com>
Date: Mon, 30 May 2022 22:46:56 +0800
Subject: [PATCH] 【#3755】优化rabbitmq代码删除setQueueNames方法避免发送延迟
---
jeecg-boot/jeecg-boot-starter/jeecg-boot-starter-rabbitmq/src/main/java/org/jeecg/boot/starter/rabbitmq/client/RabbitMqClient.java | 10 ----------
1 file changed, 0 insertions(+), 10 deletions(-)
diff --git a/jeecg-boot/jeecg-boot-starter/jeecg-boot-starter-rabbitmq/src/main/java/org/jeecg/boot/starter/rabbitmq/client/RabbitMqClient.java b/jeecg-boot/jeecg-boot-starter/jeecg-boot-starter-rabbitmq/src/main/java/org/jeecg/boot/starter/rabbitmq/client/RabbitMqClient.java
index a6025bb..388f749 100644
--- a/jeecg-boot/jeecg-boot-starter/jeecg-boot-starter-rabbitmq/src/main/java/org/jeecg/boot/starter/rabbitmq/client/RabbitMqClient.java
+++ b/jeecg-boot/jeecg-boot-starter/jeecg-boot-starter-rabbitmq/src/main/java/org/jeecg/boot/starter/rabbitmq/client/RabbitMqClient.java
@@ -221,16 +221,6 @@ public class RabbitMqClient {
rabbitAdmin.declareBinding(binding);
SimpleDateFormat sf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
log.debug("发送时间：" + sf.format(new Date()));
- messageListenerContainer.setQueueNames(queueName);
-/* messageListenerContainer.setMessageListener(new MqListener<Message>() {
- @Override
- public void onMessage(Message message, Channel channel) {
- MqListener messageListener = SpringContextHolder.getHandler(queueName + "Listener", MqListener.class);
- if (ObjectUtil.isNotEmpty(messageListener)) {
- messageListener.onMessage(message, channel);
- }
- }
- });*/
rabbitTemplate.convertAndSend(DelayExchangeBuilder.DEFAULT_DELAY_EXCHANGE, queueName, params, message -> {
if (expiration != null && expiration > 0) {
message.getMessageProperties().setHeader("x-delay", expiration);
--
libgit2 0.22.2