CAP UseStorageLock

Author: jerviscui

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

@@ -63,6 +63,7 @@ public void ConfigureServices(IServiceCollection services)
             options =>
             {
                 options.TopicNamePrefix = "test";
+                options.UseStorageLock = true;
 
                 _ = options.UseEntityFramework<DepotDbContext>(efOptions => efOptions.Schema = "cap");
 

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

@@ -21,6 +21,12 @@ public void Handler(OrderCreatedEventData data)
         _logger.LogInformation("event received: node2 {Number}", data.Number);
     }
 
+    [CapSubscribe(OrderCreatedEventData.Name, Group = OrderConsts.MessageGroupName + "2")]
+    public void Handler2(OrderCreatedEventData data)
+    {
+        _logger.LogInformation("event received group2: node2 {Number}", data.Number);
+    }
+
     #endregion
 
 }

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

@@ -66,6 +66,7 @@ public void ConfigureServices(IServiceCollection services)
             options =>
             {
                 options.TopicNamePrefix = "test";
+                options.UseStorageLock = true;
 
                 _ = options.UseEntityFramework<OrderDbContext>(efOptions => efOptions.Schema = "cap");