From 88b0cc1007c5c9228954fde2c2ef102530d28db8 Mon Sep 17 00:00:00 2001 From: whpat124 <124653847@qq.com> Date: Thu, 23 Dec 2021 00:06:10 +0000 Subject: [PATCH] =?UTF-8?q?update=20src/main/java/io/jboot/components/mq/r?= =?UTF-8?q?abbitmq/JbootRabbitmqImpl.java.=20=E8=BF=99=E9=87=8C=E6=98=AF?= =?UTF-8?q?=E5=90=A6=E5=BA=94=E8=AF=A5=E5=8A=A0=E4=B8=8A+=20queueMode?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../java/io/jboot/components/mq/rabbitmq/JbootRabbitmqImpl.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/src/main/java/io/jboot/components/mq/rabbitmq/JbootRabbitmqImpl.java b/src/main/java/io/jboot/components/mq/rabbitmq/JbootRabbitmqImpl.java index 930cf90d..0c6ce9e5 100644 --- a/src/main/java/io/jboot/components/mq/rabbitmq/JbootRabbitmqImpl.java +++ b/src/main/java/io/jboot/components/mq/rabbitmq/JbootRabbitmqImpl.java @@ -139,7 +139,7 @@ public class JbootRabbitmqImpl extends JbootmqBase implements Jbootmq { } if (channel != null) { - channelMap.put(toChannel, channel); + channelMap.put(toChannel + queueMode, channel); } } -- Gitee