From ff1bba7679777ab3c63e8c896dba9b2852686bce Mon Sep 17 00:00:00 2001
From: redkale <redkale@qq.com>
Date: Tue, 11 Jun 2024 00:43:30 +0800
Subject: [PATCH] getChannelTopic

---
 .../org/redkale/cached/CachedManager.java     | 19 +++++++++++++++++++
 .../cached/spi/CachedManagerService.java      |  6 +-----
 2 files changed, 20 insertions(+), 5 deletions(-)

diff --git a/src/main/java/org/redkale/cached/CachedManager.java b/src/main/java/org/redkale/cached/CachedManager.java
index 6000c7b66..2f2971063 100644
--- a/src/main/java/org/redkale/cached/CachedManager.java
+++ b/src/main/java/org/redkale/cached/CachedManager.java
@@ -24,6 +24,11 @@ public interface CachedManager extends Resourcable {
      */
     public static final String DEFAULT_SCHEMA = "cached-schema";
 
+    /**
+     * 默认的远程缓存订阅消息的管道名称
+     */
+    public static final String CACHED_CHANNEL_TOPIC_PREFIX = "cached-update-channel";
+
     /**
      * 资源名称
      *
@@ -39,6 +44,20 @@ public interface CachedManager extends Resourcable {
      */
     public String getSchema();
 
+    /**
+     * 远程缓存订阅消息的管道名称
+     *
+     * @return 管道名称
+     */
+    default String getChannelTopic() {
+        String n = resourceName();
+        if (n.isEmpty()) {
+            return CACHED_CHANNEL_TOPIC_PREFIX;
+        } else {
+            return CACHED_CHANNEL_TOPIC_PREFIX + ':' + n;
+        }
+    }
+
     // -------------------------------------- 本地缓存 --------------------------------------
     /**
      * 本地获取缓存数据, 过期返回null
diff --git a/src/main/java/org/redkale/cached/spi/CachedManagerService.java b/src/main/java/org/redkale/cached/spi/CachedManagerService.java
index 4dc368a13..01b96d5f0 100644
--- a/src/main/java/org/redkale/cached/spi/CachedManagerService.java
+++ b/src/main/java/org/redkale/cached/spi/CachedManagerService.java
@@ -43,7 +43,7 @@ import org.redkale.util.TypeToken;
 @ResourceType(CachedManager.class)
 public class CachedManagerService implements CachedManager, Service {
 
-    public static final String CACHED_CHANNEL_TOPIC_PREFIX = "cached-update-channel:";
+    public static final String CACHED_CHANNEL_TOPIC_PREFIX = "cached-update-channel";
 
     protected final Logger logger = Logger.getLogger(getClass().getSimpleName());
 
@@ -177,10 +177,6 @@ public class CachedManagerService implements CachedManager, Service {
         }
     }
 
-    public String getChannelTopic() {
-        return CACHED_CHANNEL_TOPIC_PREFIX + resourceName();
-    }
-
     @Override
     public String toString() {
         return getClass().getSimpleName() + "_" + Objects.hash(this) + "{name = '" + name + "', schema = '" + schema