Nybus DLQ (#29)

Updated to Nybus 1.6.0 and added error queues for templates
keghub · Jan 28, 2022 · 1b3ef90 · 1b3ef90
1 parent 801a629
commit 1b3ef90
Show file tree

Hide file tree

Showing 5 changed files with 53 additions and 11 deletions.
diff --git a/content/HostedService/HostedService.csproj b/content/HostedService/HostedService.csproj
@@ -18,9 +18,9 @@
   </ItemGroup>
 
   <ItemGroup Condition="'$(Nybus)' == 'Current'">
-    <PackageReference Include="Nybus" Version="1.5.3" />
-    <PackageReference Include="Nybus.Extensions.Hosting.HostedService" Version="1.5.3" />
-    <PackageReference Include="Nybus.Engine.RabbitMq" Version="1.5.3" />
+    <PackageReference Include="Nybus" Version="1.6.0" />
+    <PackageReference Include="Nybus.Extensions.Hosting.HostedService" Version="1.6.0" />
+    <PackageReference Include="Nybus.Engine.RabbitMq" Version="1.6.0" />
   </ItemGroup>
   <ItemGroup Condition="'$(Nybus)' == 'Legacy'">
     <PackageReference Include="Nybus.Core" Version="0.6.3" />

diff --git a/content/HostedService/appsettings.json b/content/HostedService/appsettings.json
@@ -61,8 +61,29 @@
         },
         "EventExchange": {
           "IsDurable": true
+        },
+        "CommandQueue": {
+          "ProviderName": "static",
+          "QueueName": "Hosted_Service"
+        },
+        "EventQueue": {
+          "ProviderName": "prefix",
+          "Prefix": "Hosted_Service"
+        },
+        "ErrorQueue": {
+          "ProviderName": "static",
+          "QueueName": "Hosted_Service_error"
+        }
+      },
+      "CommandErrorFilters": [
+        {
+          "type": "retry",
+          "maxRetries": 5
+        },
+        {
+          "type": "dead-letter-queue"
         }
-      }
+      ]
     }
     //#endif
 }
diff --git a/content/WebApiHost/WebApiHost.csproj b/content/WebApiHost/WebApiHost.csproj
@@ -17,9 +17,9 @@
     <PackageReference Include="EMG.Wcf.Discovery" Version="1.0.25" />
 <!--#endif-->
 <!--#if (AddNybus) -->
-    <PackageReference Include="Nybus.Engine.RabbitMq" Version="1.5.1" />
-    <PackageReference Include="Nybus" Version="1.5.1" />
-    <PackageReference Include="Nybus.Extensions.Hosting.HostedService" Version="1.5.1" />
+    <PackageReference Include="Nybus.Engine.RabbitMq" Version="1.6.0" />
+    <PackageReference Include="Nybus" Version="1.6.0" />
+    <PackageReference Include="Nybus.Extensions.Hosting.HostedService" Version="1.6.0" />
 <!--#endif -->
 <!--#if (AddNybusBridge || ConfigureAWS) -->
     <PackageReference Include="AWSSDK.Extensions.NETCore.Setup" Version="3.3.100.1" />

diff --git a/content/WindowsService/WindowsService.csproj b/content/WindowsService/WindowsService.csproj
@@ -19,9 +19,9 @@
   </ItemGroup>
 
   <ItemGroup Condition="'$(Nybus)' == 'Current'">
-    <PackageReference Include="Nybus" Version="1.5.2" />
-    <PackageReference Include="Nybus.Extensions.Hosting.HostedService" Version="1.5.2" />
-    <PackageReference Include="Nybus.Engine.RabbitMq" Version="1.5.2" />
+    <PackageReference Include="Nybus" Version="1.6.0" />
+    <PackageReference Include="Nybus.Extensions.Hosting.HostedService" Version="1.6.0" />
+    <PackageReference Include="Nybus.Engine.RabbitMq" Version="1.6.0" />
   </ItemGroup>
   <ItemGroup Condition="'$(Nybus)' == 'Legacy'">
     <PackageReference Include="Nybus.Core" Version="0.6.3" />

diff --git a/content/WindowsService/appsettings.json b/content/WindowsService/appsettings.json
@@ -61,8 +61,29 @@
       },
       "EventExchange": {
         "IsDurable": true
+      },
+      "CommandQueue": {
+        "ProviderName": "static",
+        "QueueName": "WindowsService"
+      },
+      "EventQueue": {
+        "ProviderName": "prefix",
+        "Prefix": "WindowsService"
+      },
+      "ErrorQueue": {
+        "ProviderName": "static",
+        "QueueName": "WindowsService_error"
       }
-    }
+    },
+    "CommandErrorFilters": [
+      {
+        "type": "retry",
+        "maxRetries": 5
+      },
+      {
+        "type": "dead-letter-queue"
+      }
+    ]
   }
   //#endif
 }