From cc23b44409d661727373b8c563eaffaf4c6cf70f Mon Sep 17 00:00:00 2001
From: Redkale <8730487+redkale@users.noreply.github.com>
Date: Wed, 3 Jun 2020 15:48:40 +0800
Subject: [PATCH]

---
 src/org/redkale/mq/MessageAgent.java | 5 ++++-
 1 file changed, 4 insertions(+), 1 deletion(-)

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) {