diff --git a/src/org/redkale/mq/MessageAgent.java b/src/org/redkale/mq/MessageAgent.java
index 699a02f0a..3141928a5 100644
--- a/src/org/redkale/mq/MessageAgent.java
+++ b/src/org/redkale/mq/MessageAgent.java
@@ -56,7 +56,10 @@ public abstract class MessageAgent {
     }
 
     public CompletableFuture<Void> stop() {
-        return null;
+        this.httpNodes.values().forEach(node -> {
+            node.consumer.close();
+        });
+        return CompletableFuture.completedFuture(null);
     }
 
     public void destroy(AnyValue config) {