Commit 26b41e388291db4c70cf04d10763d13423045813
1 parent
cbc1b6b4
【#3755】优化rabbitmq代码删除setQueueNames方法避免发送延迟
Showing
1 changed file
with
0 additions
and
10 deletions
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 { | @@ -221,16 +221,6 @@ public class RabbitMqClient { | ||
| 221 | rabbitAdmin.declareBinding(binding); | 221 | rabbitAdmin.declareBinding(binding); |
| 222 | SimpleDateFormat sf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss"); | 222 | SimpleDateFormat sf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss"); |
| 223 | log.debug("发送时间：" + sf.format(new Date())); | 223 | log.debug("发送时间：" + sf.format(new Date())); |
| 224 | - messageListenerContainer.setQueueNames(queueName); | ||
| 225 | -/* messageListenerContainer.setMessageListener(new MqListener<Message>() { | ||
| 226 | - @Override | ||
| 227 | - public void onMessage(Message message, Channel channel) { | ||
| 228 | - MqListener messageListener = SpringContextHolder.getHandler(queueName + "Listener", MqListener.class); | ||
| 229 | - if (ObjectUtil.isNotEmpty(messageListener)) { | ||
| 230 | - messageListener.onMessage(message, channel); | ||
| 231 | - } | ||
| 232 | - } | ||
| 233 | - });*/ | ||
| 234 | rabbitTemplate.convertAndSend(DelayExchangeBuilder.DEFAULT_DELAY_EXCHANGE, queueName, params, message -> { | 224 | rabbitTemplate.convertAndSend(DelayExchangeBuilder.DEFAULT_DELAY_EXCHANGE, queueName, params, message -> { |
| 235 | if (expiration != null && expiration > 0) { | 225 | if (expiration != null && expiration > 0) { |
| 236 | message.getMessageProperties().setHeader("x-delay", expiration); | 226 | message.getMessageProperties().setHeader("x-delay", expiration); |