From d9a5fed77f4f3485812e8dc0d1a24daa3149607f Mon Sep 17 00:00:00 2001 From: LittleSheep Date: Sun, 24 Aug 2025 13:19:39 +0800 Subject: [PATCH] :bug: Fix wrong queue name --- DysonNetwork.Pusher/Services/QueueBackgroundService.cs | 4 ++-- DysonNetwork.Pusher/Services/QueueService.cs | 6 ++---- 2 files changed, 4 insertions(+), 6 deletions(-) diff --git a/DysonNetwork.Pusher/Services/QueueBackgroundService.cs b/DysonNetwork.Pusher/Services/QueueBackgroundService.cs index 214459d..f7c4ac9 100644 --- a/DysonNetwork.Pusher/Services/QueueBackgroundService.cs +++ b/DysonNetwork.Pusher/Services/QueueBackgroundService.cs @@ -16,8 +16,8 @@ public class QueueBackgroundService( ) : BackgroundService { - private const string QueueName = "pusher.queue"; - private const string QueueGroup = "pusher.workers"; + public const string QueueName = "pusher.queue"; + public const string QueueGroup = "pusher.workers"; private readonly int _consumerCount = configuration.GetValue("ConsumerCount") ?? Environment.ProcessorCount; private readonly List _consumerTasks = []; diff --git a/DysonNetwork.Pusher/Services/QueueService.cs b/DysonNetwork.Pusher/Services/QueueService.cs index 3d1ced9..8e1f69e 100644 --- a/DysonNetwork.Pusher/Services/QueueService.cs +++ b/DysonNetwork.Pusher/Services/QueueService.cs @@ -6,8 +6,6 @@ namespace DysonNetwork.Pusher.Services; public class QueueService(INatsConnection nats) { - private const string QueueName = "pusher_queue"; - public async Task EnqueueEmail(string toName, string toAddress, string subject, string body) { var message = new QueueMessage @@ -22,7 +20,7 @@ public class QueueService(INatsConnection nats) }) }; var rawMessage = GrpcTypeHelper.ConvertObjectToByteString(message).ToByteArray(); - await nats.PublishAsync(QueueName, rawMessage); + await nats.PublishAsync(QueueBackgroundService.QueueName, rawMessage); } public async Task EnqueuePushNotification(Notification.Notification notification, Guid userId, bool isSavable = false) @@ -37,7 +35,7 @@ public class QueueService(INatsConnection nats) Data = JsonSerializer.Serialize(notification) }; var rawMessage = GrpcTypeHelper.ConvertObjectToByteString(message).ToByteArray(); - await nats.PublishAsync(QueueName, rawMessage); + await nats.PublishAsync(QueueBackgroundService.QueueName, rawMessage); } }