Update pubsub/redis/redis.go

Signed-off-by: Bernd Verst <github@bernd.dev>
dapr · Jan 25, 2024 · 7dbbc24 · 7dbbc24
1 parent 1b48de9
commit 7dbbc24
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/pubsub/redis/redis.go b/pubsub/redis/redis.go
@@ -199,7 +199,7 @@ func (r *redisStreams) createRedisMessageWrapper(ctx context.Context, stream str
 		metadataStr := metadataValue.(string)
 		err := json.Unmarshal([]byte(metadataStr), &metadata)
 		if err != nil {
-			r.logger.Warnf("Could not extract metadata for Redis message %s: %v", msg.ID, err)
+			r.logger.Warnf("Redis PubSub: Could not extract metadata for Redis message %s: %v", msg.ID, err)
 		}
 	}