非空

2023-10-13 22:06:47 +08:00
parent 98ff3cdfcf
commit bad571aecb
1 changed files with 1 additions and 1 deletions
--- 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<String> topics = new ArrayList<>();
-        if (this.httpMessageClient.isEmpty()) {
+        if (!this.httpMessageClient.isEmpty()) {
            topics.addAll(this.httpMessageClient.getTopics());
        }
        if (!this.sncpMessageClient.isEmpty()) {