Adding metadata to IQueueHandler (#8)

* Adding metadata to IQueueHandler

* update version

---------

Author: natalidahary

.DS_Store

@@ -30,7 +30,7 @@ public AzureServiceBusQueueListener(
         });
     }
 
-    public async Task StartAsync(Func<T, Func<Task>, CancellationToken, Task> handler, CancellationToken cancellationToken)
+    public async Task StartAsync(Func<T, IReadOnlyDictionary<string, string>?, Func<Task>, CancellationToken, Task> handler, CancellationToken cancellationToken)
     {
         var retryPolicy = _retryPolicyProvider.Create(_settings, _logger);
 
@@ -80,9 +80,13 @@ void ArmCancelAfterFromLockedUntil()
                     return;
                 }
 
+                // Extract application properties as metadata
+                var metadata = args.Message.ApplicationProperties
+                    .ToDictionary(kvp => kvp.Key, kvp => kvp.Value?.ToString() ?? string.Empty);
+
                 await retryPolicy.ExecuteAsync(async () =>
                 {
-                    await handler(msg, renewLock, linkedCts.Token);
+                    await handler(msg, metadata, renewLock, linkedCts.Token);
 
                     if (_settings.ProcessingDelayMs > 0)
                     {

AzureServiceBusQueueListener.cs

@@ -6,7 +6,7 @@
     <Nullable>enable</Nullable>
     <GeneratePackageOnBuild>true</GeneratePackageOnBuild>
     <PackageId>DotQueue</PackageId>
-    <Version>1.0.1</Version>
+    <Version>1.0.2</Version>
     <Authors>Alexander Kulyabin</Authors>
     <Company>Zionet</Company>
     <Description>Generic queue listener</Description>
@@ -18,7 +18,7 @@
   <ItemGroup>
     <PackageReference Include="Azure.Messaging.ServiceBus" Version="7.20.1" />
     <PackageReference Include="Microsoft.Extensions.Hosting.Abstractions" Version="9.0.8" />
-    <PackageReference Include="Microsoft.Extensions.Logging" Version="10.0.0-preview.6.25358.103" />
+    <PackageReference Include="Microsoft.Extensions.Logging" Version="9.0.8" />
     <PackageReference Include="Polly" Version="8.6.2" />
   </ItemGroup>
 

DotQueue.csproj

@@ -2,5 +2,5 @@
 
 public interface IQueueHandler<T>
 {
-    Task HandleAsync(T message, Func<Task> renewLock, CancellationToken cancellationToken);
+    Task HandleAsync(T message, IReadOnlyDictionary<string, string>? metadataCallback, Func<Task> renewLock, CancellationToken cancellationToken);
 }

IQueueHandler.cs

@@ -2,5 +2,5 @@
 
 public interface IQueueListener<T>
 {
-    Task StartAsync(Func<T, Func<Task>, CancellationToken, Task> handler, CancellationToken cancellationToken);
+    Task StartAsync(Func<T, IReadOnlyDictionary<string, string>?, Func<Task>, CancellationToken, Task> handler, CancellationToken cancellationToken);
 }

IQueueListener.cs

@@ -15,10 +15,10 @@ public QueueProcessor(IQueueListener<T> listener, IServiceScopeFactory scopeFact
     }
 
     protected override Task ExecuteAsync(CancellationToken stoppingToken) =>
-        _listener.StartAsync(async (msg, renewLock, token) =>
-        {
-            using var scope = _scopeFactory.CreateScope();
-            var handler = scope.ServiceProvider.GetRequiredService<IQueueHandler<T>>();
-            await handler.HandleAsync(msg, renewLock, token);
-        }, stoppingToken);
+    _listener.StartAsync(async (msg, metadata, renewLock, token) =>
+    {
+        using var scope = _scopeFactory.CreateScope();
+        var handler = scope.ServiceProvider.GetRequiredService<IQueueHandler<T>>();
+        await handler.HandleAsync(msg, metadata, renewLock, token);
+    }, stoppingToken);
 }