Skip to content

Commit 0f33079

Browse files
committed
Remove unused redis channels
1 parent 6ae98cb commit 0f33079

File tree

2 files changed

+3
-6
lines changed

2 files changed

+3
-6
lines changed

API/Realtime/RedisSubscriberService.cs

Lines changed: 2 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -47,9 +47,8 @@ public RedisSubscriberService(
4747
/// <inheritdoc />
4848
public async Task StartAsync(CancellationToken cancellationToken)
4949
{
50-
await _subscriber.SubscribeAsync(RedisChannels.KeyEventExpired, (_, message) => { LucTask.Run(() => HandleKeyDelOrExpired(message)); });
50+
await _subscriber.SubscribeAsync(RedisChannels.KeyEventExpired, (_, message) => { LucTask.Run(() => HandleKeyExpired(message)); });
5151
await _subscriber.SubscribeAsync(RedisChannels.DeviceOnlineStatus, (_, message) => { LucTask.Run(() => HandleDeviceOnlineStatus(message)); });
52-
await _subscriber.SubscribeAsync(RedisChannels.KeyEventDel, (_, message) => { LucTask.Run(() => HandleKeyDelOrExpired(message)); });
5352
}
5453

5554
private async Task HandleDeviceOnlineStatus(RedisValue message)
@@ -61,7 +60,7 @@ private async Task HandleDeviceOnlineStatus(RedisValue message)
6160
await LogicDeviceOnlineStatus(data.Id);
6261
}
6362

64-
private async Task HandleKeyDelOrExpired(RedisValue message)
63+
private async Task HandleKeyExpired(RedisValue message)
6564
{
6665
if (!message.HasValue) return;
6766
var msg = message.ToString().Split(':');

Common/Services/RedisPubSub/RedisChannels.cs

Lines changed: 1 addition & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -5,9 +5,7 @@ namespace OpenShock.Common.Services.RedisPubSub;
55
public static class RedisChannels
66
{
77
public static readonly RedisChannel KeyEventExpired = new("__keyevent@0__:expired", RedisChannel.PatternMode.Literal);
8-
public static readonly RedisChannel KeyEventJsonSet = new("__keyevent@0__:json.set", RedisChannel.PatternMode.Literal);
9-
public static readonly RedisChannel KeyEventDel = new("__keyevent@0__:del", RedisChannel.PatternMode.Literal);
10-
8+
119
public static readonly RedisChannel DeviceControl = new("msg-device-control", RedisChannel.PatternMode.Literal);
1210
public static readonly RedisChannel DeviceCaptive = new("msg-device-control-captive", RedisChannel.PatternMode.Literal);
1311
public static readonly RedisChannel DeviceUpdate = new("msg-device-update", RedisChannel.PatternMode.Literal);

0 commit comments

Comments
 (0)