Cleaned up parameters for clear queue

gregyjames · Feb 19, 2024 · 41784b7 · 41784b7
1 parent b4b7a46
commit 41784b7
Show file tree

Hide file tree

Showing 2 changed files with 7 additions and 8 deletions.
diff --git a/ReQueue/MessageQueue.cs b/ReQueue/MessageQueue.cs
@@ -26,8 +26,8 @@ internal MessageQueue(IDatabase database, string redisKey)
         /// <returns></returns>
         public async Task EnqueueMessages(T item)
         {
-            byte[] bytes = MessagePackSerializer.Serialize(item);
-            string base64String = Convert.ToBase64String(bytes);
+            var bytes = MessagePackSerializer.Serialize(item);
+            var base64String = Convert.ToBase64String(bytes);
             await _db.ListLeftPushAsync(_redisKey, base64String);
         }
 
@@ -50,8 +50,8 @@ public async Task DequeueMessages(Action<T> action, CancellationToken cancellati
                     if (result != RedisValue.Null)
                     {
                         // Process the item
-                        string item = result.ToString();
-                        byte[] decodedData = Convert.FromBase64String(item);
+                        var item = result.ToString();
+                        var decodedData = Convert.FromBase64String(item);
                         var deserialized = MessagePackSerializer.Deserialize<T>(decodedData);
 
                         if(filter != null)
@@ -84,11 +84,10 @@ public async Task DequeueMessages(Action<T> action, CancellationToken cancellati
         /// <summary>
         /// Clears all unprocessed items from the queue.
         /// </summary>
-        /// <param name="queueKey">The name of the queue.</param>
         /// <returns></returns>
-        public async Task ClearQueue(string queueKey)
+        public async Task ClearQueue()
         {
-            await _db.KeyDeleteAsync(queueKey);
+            await _db.KeyDeleteAsync(_redisKey);
         }
     }
 }
diff --git a/ReQueueClient/Program.cs b/ReQueueClient/Program.cs
@@ -21,7 +21,7 @@ static async Task Main(string[] args)
                 }, tokenSource.Token, (data) => data.Foo % 2 != 0)
             );
 
-            await queue.ClearQueue("numQueue");
+            await queue.ClearQueue();
             Console.ReadLine();
         }
     }