diff --git a/src/main/java/org/redkale/mq/MessageAgent.java b/src/main/java/org/redkale/mq/MessageAgent.java index b8a13f1a5..0322b64b6 100644 --- a/src/main/java/org/redkale/mq/MessageAgent.java +++ b/src/main/java/org/redkale/mq/MessageAgent.java @@ -162,7 +162,7 @@ public abstract class MessageAgent implements Resourcable { } this.startMessageClientConsumers(); List topics = new ArrayList<>(); - if (this.httpMessageClient.isEmpty()) { + if (!this.httpMessageClient.isEmpty()) { topics.addAll(this.httpMessageClient.getTopics()); } if (!this.sncpMessageClient.isEmpty()) {