getChannelTopic

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

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