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 930cf90d7cd39209437bbee1b1ef63631f0f6a4a..0c6ce9e50f561e5b1ebda6a211a53d2ae094d55c 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); } }