From ed502daeb9396eebc824f445163ac6b6f4292a69 Mon Sep 17 00:00:00 2001
From: Redkale <8730487+redkale@users.noreply.github.com>
Date: Tue, 10 Nov 2020 21:11:11 +0800
Subject: [PATCH]

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

diff --git a/src/org/redkale/mq/MessageAgent.java b/src/org/redkale/mq/MessageAgent.java
index b7cd3c193..7b4309b40 100644
--- a/src/org/redkale/mq/MessageAgent.java
+++ b/src/org/redkale/mq/MessageAgent.java
@@ -75,6 +75,10 @@ public abstract class MessageAgent {
         this.timeoutExecutor.setRemoveOnCancelPolicy(true);
     }
 
+    public boolean isHashPool() {
+        return this.workExecutor != null;
+    }
+
     public CompletableFuture<Map<String, Long>> start() {
         final LinkedHashMap<String, Long> map = new LinkedHashMap<>();
         final List<CompletableFuture> futures = new ArrayList<>();