implement processors as interface in example

Author: amirkaws

examples/BatchProcessing/src/HelloWorld/Function.cs

@@ -90,7 +90,7 @@ public BatchItemFailuresResponse HandlerUsingAttributeAndCustomBatchProcessor(SQ
     [Logging(LogEvent = true)]
     public BatchItemFailuresResponse HandlerUsingAttributeAndCustomBatchProcessorProvider(SQSEvent _)
     {
-        var batchProcessor = Services.Provider.GetRequiredService<CustomSqsBatchProcessor>();
+        var batchProcessor = Services.Provider.GetRequiredService<ISqsBatchProcessor>();
         return batchProcessor.ProcessingResult.BatchItemFailuresResponse;
     }
 
@@ -107,8 +107,8 @@ public async Task<BatchItemFailuresResponse> HandlerUsingUtility(SQSEvent sqsEve
     [Logging(LogEvent = true)]
     public async Task<BatchItemFailuresResponse> HandlerUsingUtilityFromIoc(SQSEvent sqsEvent)
     {
-        var batchProcessor = Services.Provider.GetRequiredService<CustomSqsBatchProcessor>();
-        var recordHandler = Services.Provider.GetRequiredService<CustomSqsRecordHandler>();
+        var batchProcessor = Services.Provider.GetRequiredService<ISqsBatchProcessor>();
+        var recordHandler = Services.Provider.GetRequiredService<ISqsRecordHandler>();
         var result = await batchProcessor.ProcessAsync(sqsEvent, recordHandler);
         return result.BatchItemFailuresResponse;
     }

examples/BatchProcessing/src/HelloWorld/Services.cs

@@ -14,6 +14,7 @@
  */
 
 using System;
+using AWS.Lambda.Powertools.BatchProcessing.Sqs;
 using HelloWorld.Sqs;
 using Microsoft.Extensions.DependencyInjection;
 
@@ -33,8 +34,8 @@ public static IServiceProvider Init()
     private static IServiceProvider Build()
     {
         var services = new ServiceCollection();
-        services.AddSingleton<CustomSqsBatchProcessor>();
-        services.AddSingleton<CustomSqsRecordHandler>();
+        services.AddSingleton<ISqsBatchProcessor, CustomSqsBatchProcessor>();
+        services.AddSingleton<ISqsRecordHandler, CustomSqsRecordHandler>();
         return services.BuildServiceProvider();
     }
 }

examples/BatchProcessing/src/HelloWorld/Sqs/CustomSqsBatchProcessorProvider.cs

@@ -15,6 +15,7 @@
 
 using Amazon.Lambda.SQSEvents;
 using AWS.Lambda.Powertools.BatchProcessing;
+using AWS.Lambda.Powertools.BatchProcessing.Sqs;
 using AWS.Lambda.Powertools.Logging;
 using Microsoft.Extensions.DependencyInjection;
 
@@ -24,6 +25,6 @@ internal class CustomSqsBatchProcessorProvider : IBatchProcessorProvider<SQSEven
     public IBatchProcessor<SQSEvent, SQSEvent.SQSMessage> Create()
     {
         Logger.LogInformation($"Creating SQS batch processor using: '{GetType().Name}'.");
-        return Services.Provider.GetRequiredService<CustomSqsBatchProcessor>();
+        return Services.Provider.GetRequiredService<ISqsBatchProcessor>();
     }
 }

examples/BatchProcessing/src/HelloWorld/Sqs/CustomSqsRecordHandlerProvider.cs

@@ -15,13 +15,14 @@
 
 using Amazon.Lambda.SQSEvents;
 using AWS.Lambda.Powertools.BatchProcessing;
+using AWS.Lambda.Powertools.BatchProcessing.Sqs;
 using Microsoft.Extensions.DependencyInjection;
 
 namespace HelloWorld.Sqs;
 internal class CustomSqsRecordHandlerProvider : IRecordHandlerProvider<SQSEvent.SQSMessage>
 {
     public IRecordHandler<SQSEvent.SQSMessage> Create()
     {
-        return Services.Provider.GetRequiredService<CustomSqsRecordHandler>();
+        return Services.Provider.GetRequiredService<ISqsRecordHandler>();
     }
 }