Add CAP.RedisStreams tests

Author: jerviscui

src/plugins/CAP/CapTest.Depot.Host/Program.cs

@@ -1,20 +1,27 @@
-using Microsoft.AspNetCore.Hosting;
-using Microsoft.Extensions.Hosting;
+namespace CapTest.Depot.Host;
 
-namespace CapTest.Depot.Host
+public class Program
 {
-    public class Program
-    {
-        public static void Main(string[] args)
-        {
-            CreateHostBuilder(args).Build().Run();
-        }
 
-        public static IHostBuilder CreateHostBuilder(string[] args) =>
-            Microsoft.Extensions.Hosting.Host.CreateDefaultBuilder(args)
-                .ConfigureWebHostDefaults(webBuilder =>
+    #region Constants & Statics
+
+    public static IHostBuilder CreateHostBuilder(string[] args)
+    {
+        return Microsoft.Extensions.Hosting.Host
+            .CreateDefaultBuilder(args)
+            .ConfigureLogging((logging) => logging.AddConsole())
+            .ConfigureWebHostDefaults(
+                webBuilder =>
                 {
                     webBuilder.UseStartup<Startup>();
                 });
     }
+
+    public static void Main(string[] args)
+    {
+        CreateHostBuilder(args).Build().Run();
+    }
+
+    #endregion
+
 }

src/plugins/CAP/CapTest.Order.Host/Program.cs

@@ -1,20 +1,27 @@
-using Microsoft.AspNetCore.Hosting;
-using Microsoft.Extensions.Hosting;
+namespace CapTest.Order.Host;
 
-namespace CapTest.Order.Host
+public class Program
 {
-    public class Program
-    {
-        public static void Main(string[] args)
-        {
-            CreateHostBuilder(args).Build().Run();
-        }
 
-        public static IHostBuilder CreateHostBuilder(string[] args) =>
-            Microsoft.Extensions.Hosting.Host.CreateDefaultBuilder(args)
-                .ConfigureWebHostDefaults(webBuilder =>
+    #region Constants & Statics
+
+    public static IHostBuilder CreateHostBuilder(string[] args)
+    {
+        return Microsoft.Extensions.Hosting.Host
+            .CreateDefaultBuilder(args)
+            .ConfigureLogging((logging) => logging.AddConsole())
+            .ConfigureWebHostDefaults(
+                webBuilder =>
                 {
                     webBuilder.UseStartup<Startup>();
                 });
     }
+
+    public static void Main(string[] args)
+    {
+        CreateHostBuilder(args).Build().Run();
+    }
+
+    #endregion
+
 }

src/plugins/CAP/CapTest.Order.Service/OrderCreatedEventHandler.cs

@@ -7,17 +7,6 @@ namespace CapTest.Order.Service;
 
 public class OrderCreatedEventHandler : ICapSubscribe
 {
-
-    #region Constants & Statics
-
-    [CapSubscribe(OrderConsts.HeaderMessageName)]
-    public static void MessageWithHeaders(string data, [FromCap] CapHeader header)
-    {
-        var value = header["msg-by-header"];
-    }
-
-    #endregion
-
     private readonly IConfiguration _configuration;
     private readonly ILogger<OrderCreatedEventHandler> _logger;
 
@@ -38,6 +27,14 @@ public void Handler(OrderCreatedEventData data)
         _logger.LogInformation($"event received: node1 {data.Number}");
     }
 
+    [CapSubscribe(OrderConsts.HeaderMessageName)]
+#pragma warning disable CA1822 // Mark members as static
+    public void MessageWithHeaders(string data, [FromCap] CapHeader header)
+#pragma warning restore CA1822 // Mark members as static
+    {
+        var value = header["msg-by-header"];
+    }
+
     #endregion
 
 }