Update ResourceAcquiredListener.cs

lantanagroup · Aug 5, 2024 · aff2514 · aff2514
1 parent f5b26e4
commit aff2514
Showing 1 changed file with 5 additions and 0 deletions.
diff --git a/DotNet/Normalization/Listeners/ResourceAcquiredListener.cs b/DotNet/Normalization/Listeners/ResourceAcquiredListener.cs
@@ -129,6 +129,11 @@ await kafkaConsumer.ConsumeWithInstrumentation(async (result, CancellationToken)
                         try
                         {
                             config = await configManager.SingleOrDefaultAsync(c => c.FacilityId == messageMetaData.facilityId, cancellationToken);
+
+                            if (config == null)
+                            {
+                                throw new NoEntityFoundException("Config for facilityId does not exist.");
+                            }
                         }
                         catch(DbContextNullException ex)
                         {