From 30213e9b0b869fc9a11856401983e28b19d06847 Mon Sep 17 00:00:00 2001
From: redkale <redkale@qq.com>
Date: Fri, 8 Sep 2023 13:12:22 +0800
Subject: [PATCH] CacheMemorySource

---
 src/main/java/org/redkale/source/CacheMemorySource.java | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/src/main/java/org/redkale/source/CacheMemorySource.java b/src/main/java/org/redkale/source/CacheMemorySource.java
index 63f688d0c..f9e275616 100644
--- a/src/main/java/org/redkale/source/CacheMemorySource.java
+++ b/src/main/java/org/redkale/source/CacheMemorySource.java
@@ -200,7 +200,7 @@ public final class CacheMemorySource extends AbstractCacheSource {
     //------------------------ 订阅发布 SUB/PUB ------------------------ 
     @Override
     public CompletableFuture<List<String>> pubsubChannelsAsync(@Nullable String pattern) {
-        Predicate<String> predicate = Pattern.compile(pattern).asPredicate();
+        Predicate<String> predicate = isEmpty(pattern) ? t -> true : Pattern.compile(pattern).asPredicate();
         return CompletableFuture.completedFuture(pubsubListeners.keySet().stream().filter(predicate).collect(Collectors.toList()));
     }