Wired up SQS message handler

Kralizek · Nov 10, 2022 · 44e696f · 44e696f
1 parent 179d57b
commit 44e696f
Show file tree

Hide file tree

Showing 2 changed files with 22 additions and 2 deletions.
diff --git a/SqsEventHandlerFunction/Function.cs b/SqsEventHandlerFunction/Function.cs
@@ -1,5 +1,7 @@
+using System.Collections.Generic;
 using Amazon.Lambda.Core;
 using Amazon.Lambda.SQSEvents;
+using Amazon.SimpleNotificationService;
 using Kralizek.Lambda;
 using Microsoft.Extensions.Configuration;
 using Microsoft.Extensions.DependencyInjection;
@@ -11,8 +13,24 @@ namespace SqsEventHandlerFunction;
 
 public class Function : EventFunction<SQSEvent>
 {
+    protected override void Configure(IConfigurationBuilder builder)
+    {
+        builder.AddInMemoryCollection(new Dictionary<string, string>
+        {
+            ["Options:TopicArn"] = "ARN of my SNS topic"
+        });
+    }
+
     protected override void ConfigureServices(IServiceCollection services, IExecutionEnvironment executionEnvironment)
     {
-        services.UseQueueMessageHandler<Entry, SqsMessageHandler>();
+        services.UseQueueMessageHandler<Entry, SqsMessageHandler>().WithParallelExecution();
+
+        services.AddAWSService<IAmazonSimpleNotificationService>();
+
+        services.Configure<SqsMessageHandlerOptions>(Configuration.GetSection("Options"));
+
+        services.UseCustomMessageSerializer<CustomSerializer>();
+
+        services.AddSingleton<IItemProcessor, NullItemProcessor>();
     }
 }
diff --git a/SqsEventHandlerFunction/SqsEventHandlerFunction.csproj b/SqsEventHandlerFunction/SqsEventHandlerFunction.csproj
@@ -10,9 +10,11 @@
   </PropertyGroup>
 
   <ItemGroup>
+    <PackageReference Include="AWSSDK.EXtensions.NETCore.Setup" Version="3.7.2" />
     <PackageReference Include="AWSSDK.SimpleNotificationService" Version="3.7.100.9" />
     <PackageReference Include="Kralizek.Lambda.Template" Version="5.0.0" /> 
-    <PackageReference Include="Kralizek.Lambda.Template.Sqs" Version="5.0.0" />
+    <PackageReference Include="Kralizek.Lambda.Template.Sqs" Version="5.0.0" /> 
+    <PackageReference Include="Microsoft.Extensions.Options.ConfigurationExtensions" Version="6.0.0" />
   </ItemGroup>
 
 </Project>