notfire/Iceshrimp.NET
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

[backend/core] Fix NullReferenceException

Browse source
This commit is contained in:
Laura Hausmann 2024-03-24 00:25:27 +01:00
parent 9698e3d36d
commit 188a6f4251
No known key found for this signature in database
GPG key ID: D044E84C5BE01605
1 changed files with 1 additions and 1 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

2
Iceshrimp.Backend/Core/Services/QueueService.cs
View file

@ -32,7 +32,6 @@ public class QueueService(IServiceScopeFactory scopeFactory) : BackgroundService
{ {
_queues.AddRange([InboxQueue, PreDeliverQueue, DeliverQueue, BackgroundTaskQueue]); _queues.AddRange([InboxQueue, PreDeliverQueue, DeliverQueue, BackgroundTaskQueue]);
await RecoverOrPrepareForExitAsync();
token.Register(RecoverOrPrepareForExit); token.Register(RecoverOrPrepareForExit);
_ = Task.Run(RegisterNotificationChannels, token); _ = Task.Run(RegisterNotificationChannels, token);
@ -147,6 +146,7 @@ public class PostgresJobQueue<T>(
public async Task ExecuteAsync(IServiceScopeFactory scopeFactory, CancellationToken token) public async Task ExecuteAsync(IServiceScopeFactory scopeFactory, CancellationToken token)
{ {
_scopeFactory = scopeFactory; _scopeFactory = scopeFactory;
await RecoverOrPrepareForExitAsync();
QueuedChannelEvent += (_, _) => _queuedChannel.Set(); QueuedChannelEvent += (_, _) => _queuedChannel.Set();
DelayedChannelEvent += (_, _) => _delayedChannel.Set(); DelayedChannelEvent += (_, _) => _delayedChannel.Set();