Skip to content

Commit 403e9b8

Browse files
authored
Correct Redis keys prefix (#680)
* Correct Redis keys prefix * .
1 parent 6a0ceeb commit 403e9b8

File tree

1 file changed

+5
-5
lines changed

1 file changed

+5
-5
lines changed

source/Halibut/Queue/Redis/RedisHelpers/RedisFacade.cs

Lines changed: 5 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -35,7 +35,7 @@ public RedisFacade(string configuration, string keyPrefix, ILog log) : this(Conf
3535
}
3636
public RedisFacade(ConfigurationOptions redisOptions, string keyPrefix, ILog log)
3737
{
38-
this.keyPrefix = keyPrefix;
38+
this.keyPrefix = keyPrefix + ":HalibutRedis";
3939
this.log = log.ForContext<RedisFacade>();
4040
objectLifetimeCts = new CancelOnDisposeCancellationToken();
4141
objectLifeTimeCancellationToken = objectLifetimeCts.Token;
@@ -188,7 +188,7 @@ public async Task<IAsyncDisposable> SubscribeToChannel(string channelName, Func<
188188

189189
string ToPrefixedChannelName(string channelName)
190190
{
191-
return "channel:" + keyPrefix + ":" + channelName;
191+
return keyPrefix + ":channel:" + channelName;
192192
}
193193

194194
public async Task PublishToChannel(string channelName, string payload, CancellationToken cancellationToken)
@@ -218,7 +218,7 @@ await ExecuteWithRetry(async () =>
218218

219219
RedisKey ToHashKey(string key)
220220
{
221-
return "hash:" + keyPrefix + ":" + key;
221+
return keyPrefix + ":hash:" + key;
222222
}
223223

224224
public async Task<bool> HashContainsKey(string key, string field, CancellationToken cancellationToken)
@@ -297,7 +297,7 @@ await ExecuteWithRetry(async () =>
297297

298298
RedisKey ToListKey(string key)
299299
{
300-
return "list:" + keyPrefix + ":" + key;
300+
return keyPrefix + ":list:" + key;
301301
}
302302

303303
public async Task ListRightPushAsync(string key, string payload, TimeSpan ttlForAllInList, CancellationToken cancellationToken)
@@ -330,7 +330,7 @@ await ExecuteWithRetry(async () =>
330330

331331
RedisKey ToStringKey(string key)
332332
{
333-
return "string:" + keyPrefix + ":" + key;
333+
return keyPrefix + ":string:" + key;
334334
}
335335

336336
public async Task SetString(string key, string value, TimeSpan ttl, CancellationToken cancellationToken)

0 commit comments

Comments
 (0)