Prefix routing key

Author: ogbanugot

brokers/redis/config.go

@@ -30,7 +30,7 @@ func (rc *RedisConfig) Init() error {
 	}
 
 	if rc.StreamGroup == "" {
-		rc.StreamGroup = "disq:"
+		rc.StreamGroup = "disq"
 	}
 
 	if rc.Concurency == 0 {

brokers/redis/list.go

@@ -38,7 +38,7 @@ func NewList(cfg *RedisConfig) disq.Broker {
 	}
 	broker := &List{
 		Redis:        cfg.Redis,
-		list:         cfg.Name + ":list",
+		list:         "disq:" + "{" + cfg.Name + ":list",
 		opts:         cfg,
 		consumerName: disq.ConsumerName(),
 		buffer:       make(chan *disq.Message, cfg.BufferSize),

brokers/redis/stream.go

@@ -44,8 +44,8 @@ func NewStream(cfg *RedisConfig) disq.Broker {
 	}
 	broker := &Stream{
 		Redis:        cfg.Redis,
-		zset:         cfg.Name + ":zset",
-		stream:       cfg.Name + ":stream",
+		zset:         "disq:" + "{" + cfg.Name + "}:zset",
+		stream:       "disq:" + "{" + cfg.Name + "}:stream",
 		streamGroup:  cfg.StreamGroup,
 		consumerName: disq.ConsumerName(),
 		opts:         cfg,