fix: performance when multiple messages scheduled need to be consumed

uniteeio · Nov 8, 2022 · 3992ef3 · 3992ef3
1 parent 6b543dc
commit 3992ef3
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/Unitee.EventDriven.RedisStream/RedisStreamBackgroundReceiver.cs b/Unitee.EventDriven.RedisStream/RedisStreamBackgroundReceiver.cs
@@ -189,7 +189,6 @@ where attributes.Cast<SubjectAttribute>().FirstOrDefault()?.Subject == message.S
 
                             var body = JsonSerializer.Deserialize((JsonElement)concreteBodyType, type);
 
-
                             var publisher = scope.ServiceProvider.GetRequiredService<IRedisStreamPublisher>();
 
                             var task = (Task?)publisher
@@ -221,6 +220,8 @@ where attributes.Cast<SubjectAttribute>().FirstOrDefault()?.Subject == message.S
                         await db.SortedSetRemoveAsync("SCHEDULED_MESSAGES", topMessage.Element);
                         await db.LockReleaseAsync($"LOCK:{topMessage.Element}", _serviceName);
                     }
+
+                    continue;
                 }
             }