diff --git a/Cleipnir.Tests.AspNet/IntegrationTest.cs b/Cleipnir.Tests.AspNet/IntegrationTest.cs index f17d056..c49158a 100644 --- a/Cleipnir.Tests.AspNet/IntegrationTest.cs +++ b/Cleipnir.Tests.AspNet/IntegrationTest.cs @@ -79,7 +79,7 @@ IFunctionStore functionStore bindings(builder.Services); builder.Services.AddFlows(c => c .UseStore(functionStore) - .RegisterFlows() + .RegisterFlow() ); var app = builder.Build(); diff --git a/Cleipnir.Tests/Flows/OptionsTests.cs b/Cleipnir.Tests/Flows/OptionsTests.cs index d24b7e3..26b2a9d 100644 --- a/Cleipnir.Tests/Flows/OptionsTests.cs +++ b/Cleipnir.Tests/Flows/OptionsTests.cs @@ -21,7 +21,7 @@ public async Task SimpleFlowCompletesSuccessfully() messagesDefaultMaxWaitForCompletion: TimeSpan.FromDays(1), watchdogCheckFrequency: TimeSpan.FromMilliseconds(100) )) - .RegisterFlows() + .RegisterFlow() ); serviceCollection.AddScoped(); serviceCollection.AddTransient(sp => new Flows( diff --git a/Cleipnir/AspNet/FlowsModule.cs b/Cleipnir/AspNet/FlowsModule.cs index e7a60eb..eebf1fa 100644 --- a/Cleipnir/AspNet/FlowsModule.cs +++ b/Cleipnir/AspNet/FlowsModule.cs @@ -61,7 +61,7 @@ public FlowsConfigurator WithOptions(Func optionsFunc return this; } - public FlowsConfigurator RegisterFlows() where TFlow : Flow + public FlowsConfigurator RegisterFlow() where TFlow : Flow { var added = FlowsTypes.Add(typeof(Flows)); if (!added) return this; @@ -76,7 +76,7 @@ public FlowsConfigurator RegisterFlows() where TFlow : Flow return this; } - public FlowsConfigurator RegisterFlows() where TFlow : Flow where TParam : notnull + public FlowsConfigurator RegisterFlow() where TFlow : Flow where TParam : notnull { var added = FlowsTypes.Add(typeof(Flows)); if (!added) return this; @@ -91,7 +91,7 @@ public FlowsConfigurator RegisterFlows() where TFlow : Flow() where TFlow : Flow where TParam : notnull + public FlowsConfigurator RegisterFlow() where TFlow : Flow where TParam : notnull { var added = FlowsTypes.Add(typeof(Flows)); if (!added) return this; diff --git a/README.md b/README.md index 9746f68..53fba30 100644 --- a/README.md +++ b/README.md @@ -125,7 +125,7 @@ Secondly, add the following to the setup in `Program.cs` ([source code](https:// ```csharp builder.Services.AddFlows(c => c .UsePostgresStore(connectionString) - .RegisterFlows() + .RegisterFlow() ); ``` diff --git a/Samples/Cleipnir.Sample.AspNet/Program.cs b/Samples/Cleipnir.Sample.AspNet/Program.cs index 0ceafa4..b369ccf 100644 --- a/Samples/Cleipnir.Sample.AspNet/Program.cs +++ b/Samples/Cleipnir.Sample.AspNet/Program.cs @@ -28,7 +28,7 @@ private static async Task Main(string[] args) builder.Services.AddFlows(c => c .UsePostgresStore(connectionString) .WithOptions(new Options(leaseLength: TimeSpan.FromSeconds(5))) - .RegisterFlows() + .RegisterFlow() ); // Add services to the container. diff --git a/Samples/Cleipnir.Sample.Presentation.AspNet/Program.cs b/Samples/Cleipnir.Sample.Presentation.AspNet/Program.cs index 8b889d4..a51d195 100644 --- a/Samples/Cleipnir.Sample.Presentation.AspNet/Program.cs +++ b/Samples/Cleipnir.Sample.Presentation.AspNet/Program.cs @@ -33,11 +33,11 @@ private static async Task Main(string[] args) builder.Services.AddFlows(c => c .UsePostgresStore(connectionString) .WithOptions(new Options(leaseLength: TimeSpan.FromSeconds(5), messagesDefaultMaxWaitForCompletion: TimeSpan.MaxValue)) - .RegisterFlows() - .RegisterFlows>() - .RegisterFlows() - .RegisterFlows() - .RegisterFlows() + .RegisterFlow() + .RegisterFlow>() + .RegisterFlow() + .RegisterFlow() + .RegisterFlow() ); builder.Services.AddInMemoryBus(); diff --git a/Samples/Cleipnir.Sample.Presentation/C_NewsletterSender/Distributed/Example.cs b/Samples/Cleipnir.Sample.Presentation/C_NewsletterSender/Distributed/Example.cs index 3754ccd..73a3d6f 100644 --- a/Samples/Cleipnir.Sample.Presentation/C_NewsletterSender/Distributed/Example.cs +++ b/Samples/Cleipnir.Sample.Presentation/C_NewsletterSender/Distributed/Example.cs @@ -22,7 +22,7 @@ public static async Task Perform() c => c .UseStore(store) .WithOptions(new Options(unhandledExceptionHandler: Console.WriteLine)) - .RegisterFlows() + .RegisterFlow() ); serviceCollection.AddScoped(sp => new NewsletterChildFlow(sp.GetRequiredService>(), child)); serviceCollection.AddTransient(sp => new Flows( diff --git a/Samples/Cleipnir.Sample.Presentation/C_NewsletterSender/Example.cs b/Samples/Cleipnir.Sample.Presentation/C_NewsletterSender/Example.cs index fa169cc..4627be2 100644 --- a/Samples/Cleipnir.Sample.Presentation/C_NewsletterSender/Example.cs +++ b/Samples/Cleipnir.Sample.Presentation/C_NewsletterSender/Example.cs @@ -20,7 +20,7 @@ public static async Task Perform() c => c .UseStore(store) .WithOptions(new Options(unhandledExceptionHandler: Console.WriteLine)) - .RegisterFlows() + .RegisterFlow() ); var sp = serviceCollection.BuildServiceProvider(); diff --git a/ServiceBuses/MassTransit/Cleipnir.MassTransit.Console/Program.cs b/ServiceBuses/MassTransit/Cleipnir.MassTransit.Console/Program.cs index 05afa1b..327d348 100644 --- a/ServiceBuses/MassTransit/Cleipnir.MassTransit.Console/Program.cs +++ b/ServiceBuses/MassTransit/Cleipnir.MassTransit.Console/Program.cs @@ -36,7 +36,7 @@ private static IHostBuilder CreateHostBuilder(string[] args) => { services.AddFlows(c => c .UseInMemoryStore() - .RegisterFlows() + .RegisterFlow() ); services.AddMassTransit(x => diff --git a/ServiceBuses/MassTransit/Cleipnir.MassTransit.RabbitMq.Console/Program.cs b/ServiceBuses/MassTransit/Cleipnir.MassTransit.RabbitMq.Console/Program.cs index fe7d797..619b051 100644 --- a/ServiceBuses/MassTransit/Cleipnir.MassTransit.RabbitMq.Console/Program.cs +++ b/ServiceBuses/MassTransit/Cleipnir.MassTransit.RabbitMq.Console/Program.cs @@ -45,7 +45,7 @@ private static IHostBuilder CreateHostBuilder(string[] args) => services.AddFlows(c => c .UseInMemoryStore() - .RegisterFlows() + .RegisterFlow() ); services.AddMassTransit(x => diff --git a/ServiceBuses/NServiceBus/Cleipnir.NServiceBus.Console/Program.cs b/ServiceBuses/NServiceBus/Cleipnir.NServiceBus.Console/Program.cs index 4b4fc48..feea014 100644 --- a/ServiceBuses/NServiceBus/Cleipnir.NServiceBus.Console/Program.cs +++ b/ServiceBuses/NServiceBus/Cleipnir.NServiceBus.Console/Program.cs @@ -36,7 +36,7 @@ private static IHostBuilder CreateHostBuilder(string[] args) => { services.AddFlows(c => c .UseInMemoryStore() - .RegisterFlows() + .RegisterFlow() ); }).UseNServiceBus(_ => diff --git a/ServiceBuses/Rebus/Cleipnir.Rebus.Console/Program.cs b/ServiceBuses/Rebus/Cleipnir.Rebus.Console/Program.cs index 36dec99..a73dc54 100644 --- a/ServiceBuses/Rebus/Cleipnir.Rebus.Console/Program.cs +++ b/ServiceBuses/Rebus/Cleipnir.Rebus.Console/Program.cs @@ -37,7 +37,7 @@ private static IHostBuilder CreateHostBuilder(string[] args) => { services.AddFlows(c => c .UseInMemoryStore() - .RegisterFlows() + .RegisterFlow() ); services.AutoRegisterHandlersFromAssembly(typeof(Program).Assembly); diff --git a/ServiceBuses/Wolverine/Cleipnir.Wolverine.Console/Program.cs b/ServiceBuses/Wolverine/Cleipnir.Wolverine.Console/Program.cs index 5da20cb..c4baa2d 100644 --- a/ServiceBuses/Wolverine/Cleipnir.Wolverine.Console/Program.cs +++ b/ServiceBuses/Wolverine/Cleipnir.Wolverine.Console/Program.cs @@ -37,7 +37,7 @@ private static IHostBuilder CreateHostBuilder(string[] args) => { services.AddFlows(c => c .UseInMemoryStore() - .RegisterFlows() + .RegisterFlow() ); }) .UseWolverine();