From bad571aecbda7e8cffc687d690bef02e615d6407 Mon Sep 17 00:00:00 2001 From: redkale Date: Fri, 13 Oct 2023 22:06:47 +0800 Subject: [PATCH] =?UTF-8?q?=E9=9D=9E=E7=A9=BA?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- src/main/java/org/redkale/mq/MessageAgent.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) 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()) {