diff --git a/internal/redis/wrapper.go b/internal/redis/wrapper.go index e103ed4..3e0f7c1 100644 --- a/internal/redis/wrapper.go +++ b/internal/redis/wrapper.go @@ -37,8 +37,9 @@ func SetPrefix(components ...string) { } func Key(components ...string) string { - components = append(prefix, components...) - return strings.Join(components, ".") + namespace := strings.Join(prefix, ".") + channel := strings.Join(components, ".") + return namespace + "::" + channel } func Get(key string) *_redis.StringCmd {