RavenDB-21956 Small refactoring

djordjedjukic · May 8, 2024 · b2246d1 · b2246d1
1 parent 8fcd38c
commit b2246d1
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 2 deletions.
diff --git a/...r/Documents/ETL/Providers/Queue/AzureQueueStorage/AzureQueueStorageDocumentTransformer.cs b/...r/Documents/ETL/Providers/Queue/AzureQueueStorage/AzureQueueStorageDocumentTransformer.cs
@@ -30,9 +30,9 @@ private void LoadToFunction(string queueName, ScriptRunnerResult document, Cloud
 
         var result = document.TranslateToObject(Context);
 
-        var topic = GetOrAdd(queueName);
+        var queue = GetOrAdd(queueName);
 
-        topic.Items.Add(new AzureQueueStorageItem(Current) { TransformationResult = result, Attributes = attributes });
+        queue.Items.Add(new AzureQueueStorageItem(Current) { TransformationResult = result, Attributes = attributes });
     }
 
     public override void Initialize(bool debugMode)

diff --git a/src/Raven.Server/Documents/ETL/Providers/Queue/AzureQueueStorage/AzureQueueStorageEtl.cs b/src/Raven.Server/Documents/ETL/Providers/Queue/AzureQueueStorage/AzureQueueStorageEtl.cs
@@ -1,5 +1,6 @@
 using System;
 using System.Collections.Generic;
+using System.Linq;
 using System.Text.Json;
 using System.Text.Json.Serialization;
 using Azure.Storage.Queues;
@@ -102,6 +103,7 @@ private string CreateBase64CloudEvent(AzureQueueStorageItem queueItem)
     protected override void OnProcessStopped()
     {
         _queueClients.Clear();
+        _alreadyCreatedQueues.Clear();
     }
 
     private void CreateQueueIfNotExists(QueueClient queueClient)