diff --git a/src/ParticularTemplates/NServiceBusEndpoint/Program.cs b/src/ParticularTemplates/NServiceBusEndpoint/Program.cs index c79c2591..ee3e8e81 100644 --- a/src/ParticularTemplates/NServiceBusEndpoint/Program.cs +++ b/src/ParticularTemplates/NServiceBusEndpoint/Program.cs @@ -24,121 +24,118 @@ builder.Services.AddWindowsService(); #endif -builder.UseNServiceBus(() => -{ - // TODO: consider moving common endpoint configuration into a shared project - // for use by all endpoints in the system +// TODO: consider moving common endpoint configuration into a shared project +// for use by all endpoints in the system - var endpointConfiguration = new EndpointConfiguration("ProjectName"); +var endpointConfiguration = new EndpointConfiguration("ProjectName"); #if (transport == "LearningTransport") - // Learning Transport: https://docs.particular.net/transports/learning/ - var routing = endpointConfiguration.UseTransport(new LearningTransport()); +// Learning Transport: https://docs.particular.net/transports/learning/ +var routing = endpointConfiguration.UseTransport(new LearningTransport()); #elseif (transport == "AzureServiceBus") - // Azure Service Bus Transport: https://docs.particular.net/transports/azure-service-bus/ - var transport = new AzureServiceBusTransport("CONNECTION_STRING"); - var routing = endpointConfiguration.UseTransport(transport); +// Azure Service Bus Transport: https://docs.particular.net/transports/azure-service-bus/ +var transport = new AzureServiceBusTransport("CONNECTION_STRING"); +var routing = endpointConfiguration.UseTransport(transport); #elseif (transport == "AzureStorageQueues") - // Azure Storage Queues Transport: https://docs.particular.net/transports/azure-storage-queues/ - var transport = new AzureStorageQueueTransport("DefaultEndpointsProtocol=https;AccountName=[ACCOUNT];AccountKey=[KEY];"); - var routing = endpointConfiguration.UseTransport(transport); +// Azure Storage Queues Transport: https://docs.particular.net/transports/azure-storage-queues/ +var transport = new AzureStorageQueueTransport("DefaultEndpointsProtocol=https;AccountName=[ACCOUNT];AccountKey=[KEY];"); +var routing = endpointConfiguration.UseTransport(transport); #elseif (transport == "SQS") - // Amazon SQS Transport: https://docs.particular.net/transports/sqs/ - var transport = new SqsTransport(); - var routing = endpointConfiguration.UseTransport(transport); +// Amazon SQS Transport: https://docs.particular.net/transports/sqs/ +var transport = new SqsTransport(); +var routing = endpointConfiguration.UseTransport(transport); #elseif (transport == "RabbitMQ") - // RabbitMQ Transport: https://docs.particular.net/transports/rabbitmq/ - var rabbitMqConnectionString = "CONNECTION_STRING"; - var transport = new RabbitMQTransport(RoutingTopology.Conventional(QueueType.Quorum), rabbitMqConnectionString); - var routing = endpointConfiguration.UseTransport(transport); +// RabbitMQ Transport: https://docs.particular.net/transports/rabbitmq/ +var rabbitMqConnectionString = "CONNECTION_STRING"; +var transport = new RabbitMQTransport(RoutingTopology.Conventional(QueueType.Quorum), rabbitMqConnectionString); +var routing = endpointConfiguration.UseTransport(transport); #elseif (transport == "SQL") - // SQL Server Transport: https://docs.particular.net/transports/sql/ - var transport = new SqlServerTransport("Data Source=.\\SqlExpress;Initial Catalog=dbname;Integrated Security=True"); - var routing = endpointConfiguration.UseTransport(transport); +// SQL Server Transport: https://docs.particular.net/transports/sql/ +var transport = new SqlServerTransport("Data Source=.\\SqlExpress;Initial Catalog=dbname;Integrated Security=True"); +var routing = endpointConfiguration.UseTransport(transport); #endif - // Define routing for commands: https://docs.particular.net/nservicebus/messaging/routing#command-routing - // routing.RouteToEndpoint(typeof(MessageType), "DestinationEndpointForType"); - // routing.RouteToEndpoint(typeof(MessageType).Assembly, "DestinationForAllCommandsInAssembly"); +// Define routing for commands: https://docs.particular.net/nservicebus/messaging/routing#command-routing +// routing.RouteToEndpoint(typeof(MessageType), "DestinationEndpointForType"); +// routing.RouteToEndpoint(typeof(MessageType).Assembly, "DestinationForAllCommandsInAssembly"); #if (persistence == "LearningPersistence") - // Learning Persistence: https://docs.particular.net/persistence/learning/ - endpointConfiguration.UsePersistence(); +// Learning Persistence: https://docs.particular.net/persistence/learning/ +endpointConfiguration.UsePersistence(); #elseif (persistence == "MSSQL") - // SQL Persistence: https://docs.particular.net/persistence/sql/ - // Microsoft SQL Server dialect: https://docs.particular.net/persistence/sql/dialect-mssql - var dbConnectionString = "Data Source=.\\SqlExpress;Initial Catalog=dbname;Integrated Security=True;"; - var persistence = endpointConfiguration.UsePersistence(); - persistence.SqlDialect(); - persistence.ConnectionBuilder(() => new SqlConnection(dbConnectionString)); +// SQL Persistence: https://docs.particular.net/persistence/sql/ +// Microsoft SQL Server dialect: https://docs.particular.net/persistence/sql/dialect-mssql +var dbConnectionString = "Data Source=.\\SqlExpress;Initial Catalog=dbname;Integrated Security=True;"; +var persistence = endpointConfiguration.UsePersistence(); +persistence.SqlDialect(); +persistence.ConnectionBuilder(() => new SqlConnection(dbConnectionString)); #elseif (persistence == "MySQL") - // SQL Persistence: https://docs.particular.net/persistence/sql/ - // MySQL dialect: https://docs.particular.net/persistence/sql/dialect-mysql - var dbConnectionString = "server=localhost;user=root;database=dbname;port=3306;password=pass;AllowUserVariables=True;AutoEnlist=false"; - var persistence = endpointConfiguration.UsePersistence(); - persistence.SqlDialect(); - persistence.ConnectionBuilder(() => new MySqlConnection(dbConnectionString)); +// SQL Persistence: https://docs.particular.net/persistence/sql/ +// MySQL dialect: https://docs.particular.net/persistence/sql/dialect-mysql +var dbConnectionString = "server=localhost;user=root;database=dbname;port=3306;password=pass;AllowUserVariables=True;AutoEnlist=false"; +var persistence = endpointConfiguration.UsePersistence(); +persistence.SqlDialect(); +persistence.ConnectionBuilder(() => new MySqlConnection(dbConnectionString)); #elseif (persistence == "PostgreSQL") - // SQL Persistence: https://docs.particular.net/persistence/sql/ - // PostgreSQL dialect: https://docs.particular.net/persistence/sql/dialect-postgresql - var dbConnectionString = "Server=localhost;Port=5432;Database=dbname;User Id=user;Password=pass;"; - var persistence = endpointConfiguration.UsePersistence(); - var dialect = persistence.SqlDialect(); - dialect.JsonBParameterModifier(parameter => - { - var npgsqlParameter = (NpgsqlParameter)parameter; - npgsqlParameter.NpgsqlDbType = NpgsqlDbType.Jsonb; - }); - persistence.ConnectionBuilder(() => new NpgsqlConnection(dbConnectionString)); +// SQL Persistence: https://docs.particular.net/persistence/sql/ +// PostgreSQL dialect: https://docs.particular.net/persistence/sql/dialect-postgresql +var dbConnectionString = "Server=localhost;Port=5432;Database=dbname;User Id=user;Password=pass;"; +var persistence = endpointConfiguration.UsePersistence(); +var dialect = persistence.SqlDialect(); +dialect.JsonBParameterModifier(parameter => +{ + var npgsqlParameter = (NpgsqlParameter)parameter; + npgsqlParameter.NpgsqlDbType = NpgsqlDbType.Jsonb; +}); +persistence.ConnectionBuilder(() => new NpgsqlConnection(dbConnectionString)); #elseif (persistence == "Oracle") - // SQL Persistence: https://docs.particular.net/persistence/sql/ - // Oracle dialect: https://docs.particular.net/persistence/sql/dialect-oracle - var dbConnectionString = "Data Source=localhost;User Id=username;Password=pass;Enlist=false;"; - var persistence = endpointConfiguration.UsePersistence(); - persistence.SqlDialect(); - persistence.ConnectionBuilder(() => new OracleConnection(dbConnectionString)); +// SQL Persistence: https://docs.particular.net/persistence/sql/ +// Oracle dialect: https://docs.particular.net/persistence/sql/dialect-oracle +var dbConnectionString = "Data Source=localhost;User Id=username;Password=pass;Enlist=false;"; +var persistence = endpointConfiguration.UsePersistence(); +persistence.SqlDialect(); +persistence.ConnectionBuilder(() => new OracleConnection(dbConnectionString)); #elseif (persistence == "CosmosDB") - // Cosmos DB Persistence: https://docs.particular.net/persistence/cosmosdb/ - var persistence = endpointConfiguration.UsePersistence(); - persistence.CosmosClient(new CosmosClient("CONNECTION_STRING")); - persistence.DatabaseName("DATABASE_NAME"); +// Cosmos DB Persistence: https://docs.particular.net/persistence/cosmosdb/ +var persistence = endpointConfiguration.UsePersistence(); +persistence.CosmosClient(new CosmosClient("CONNECTION_STRING")); +persistence.DatabaseName("DATABASE_NAME"); #elseif (persistence == "AzureTable") - // Azure Table Persistence: https://docs.particular.net/persistence/azure-table/ - var persistence = endpointConfiguration.UsePersistence(); - persistence.ConnectionString("DefaultEndpointsProtocol=https;AccountName=[ACCOUNT];AccountKey=[KEY];"); +// Azure Table Persistence: https://docs.particular.net/persistence/azure-table/ +var persistence = endpointConfiguration.UsePersistence(); +persistence.ConnectionString("DefaultEndpointsProtocol=https;AccountName=[ACCOUNT];AccountKey=[KEY];"); #elseif (persistence == "RavenDB") - // RavenDB Persistence: https://docs.particular.net/persistence/ravendb/ - DocumentStore documentStore; - var persistence = endpointConfiguration.UsePersistence(); - persistence.SetDefaultDocumentStore(readOnlySettings => +// RavenDB Persistence: https://docs.particular.net/persistence/ravendb/ +DocumentStore documentStore; +var persistence = endpointConfiguration.UsePersistence(); +persistence.SetDefaultDocumentStore(readOnlySettings => +{ + documentStore = new DocumentStore { - documentStore = new DocumentStore - { - Urls = new[] { "http://localhost:8080" }, - Database = readOnlySettings.EndpointName() - }; - return documentStore; - }); + Urls = new[] { "http://localhost:8080" }, + Database = readOnlySettings.EndpointName() + }; + return documentStore; +}); #elseif (persistence == "MongoDB") - // MongoDB Persistence: https://docs.particular.net/persistence/mongodb/ - var persistence = endpointConfiguration.UsePersistence(); - persistence.DatabaseName("DATABASE_NAME"); +// MongoDB Persistence: https://docs.particular.net/persistence/mongodb/ +var persistence = endpointConfiguration.UsePersistence(); +persistence.DatabaseName("DATABASE_NAME"); #elseif (persistence == "DynamoDB") - // Amazon DynamoDB Persistence: https://docs.particular.net/persistence/dynamodb/ - var persistence = endpointConfiguration.UsePersistence(); +// Amazon DynamoDB Persistence: https://docs.particular.net/persistence/dynamodb/ +var persistence = endpointConfiguration.UsePersistence(); #endif - // Message serialization - endpointConfiguration.UseSerialization(); +// Message serialization +endpointConfiguration.UseSerialization(); - endpointConfiguration.DefineCriticalErrorAction(OnCriticalError); +endpointConfiguration.DefineCriticalErrorAction(OnCriticalError); - // Installers are useful in development. Consider disabling in production. - // https://docs.particular.net/nservicebus/operations/installers - endpointConfiguration.EnableInstallers(); +// Installers are useful in development. Consider disabling in production. +// https://docs.particular.net/nservicebus/operations/installers +endpointConfiguration.EnableInstallers(); - return endpointConfiguration; -}); +builder.UseNServiceBus(endpointConfiguration); var app = builder.Build(); app.Run(); diff --git a/src/ParticularTemplates/NServiceBusEndpoint/ProjectName.csproj b/src/ParticularTemplates/NServiceBusEndpoint/ProjectName.csproj index 54e937b9..fbb78170 100644 --- a/src/ParticularTemplates/NServiceBusEndpoint/ProjectName.csproj +++ b/src/ParticularTemplates/NServiceBusEndpoint/ProjectName.csproj @@ -9,7 +9,7 @@ - + diff --git a/src/Tests/ApprovalFiles/TemplateTests.NServiceBusEndpoint.approved.txt b/src/Tests/ApprovalFiles/TemplateTests.NServiceBusEndpoint.approved.txt index 55e92fd4..a118ef22 100644 --- a/src/Tests/ApprovalFiles/TemplateTests.NServiceBusEndpoint.approved.txt +++ b/src/Tests/ApprovalFiles/TemplateTests.NServiceBusEndpoint.approved.txt @@ -29,34 +29,31 @@ using Microsoft.Extensions.Hosting; var builder = Host.CreateApplicationBuilder(args); -builder.UseNServiceBus(() => -{ - // TODO: consider moving common endpoint configuration into a shared project - // for use by all endpoints in the system +// TODO: consider moving common endpoint configuration into a shared project +// for use by all endpoints in the system - var endpointConfiguration = new EndpointConfiguration("NServiceBusEndpoint"); +var endpointConfiguration = new EndpointConfiguration("NServiceBusEndpoint"); - // Learning Transport: https://docs.particular.net/transports/learning/ - var routing = endpointConfiguration.UseTransport(new LearningTransport()); +// Learning Transport: https://docs.particular.net/transports/learning/ +var routing = endpointConfiguration.UseTransport(new LearningTransport()); - // Define routing for commands: https://docs.particular.net/nservicebus/messaging/routing#command-routing - // routing.RouteToEndpoint(typeof(MessageType), "DestinationEndpointForType"); - // routing.RouteToEndpoint(typeof(MessageType).Assembly, "DestinationForAllCommandsInAssembly"); +// Define routing for commands: https://docs.particular.net/nservicebus/messaging/routing#command-routing +// routing.RouteToEndpoint(typeof(MessageType), "DestinationEndpointForType"); +// routing.RouteToEndpoint(typeof(MessageType).Assembly, "DestinationForAllCommandsInAssembly"); - // Learning Persistence: https://docs.particular.net/persistence/learning/ - endpointConfiguration.UsePersistence(); +// Learning Persistence: https://docs.particular.net/persistence/learning/ +endpointConfiguration.UsePersistence(); - // Message serialization - endpointConfiguration.UseSerialization(); +// Message serialization +endpointConfiguration.UseSerialization(); - endpointConfiguration.DefineCriticalErrorAction(OnCriticalError); +endpointConfiguration.DefineCriticalErrorAction(OnCriticalError); - // Installers are useful in development. Consider disabling in production. - // https://docs.particular.net/nservicebus/operations/installers - endpointConfiguration.EnableInstallers(); +// Installers are useful in development. Consider disabling in production. +// https://docs.particular.net/nservicebus/operations/installers +endpointConfiguration.EnableInstallers(); - return endpointConfiguration; -}); +builder.UseNServiceBus(endpointConfiguration); var app = builder.Build(); app.Run(); diff --git a/src/Tests/ApprovalFiles/TemplateTests.NServiceBusEndpointHosting.ConsoleApp.approved.txt b/src/Tests/ApprovalFiles/TemplateTests.NServiceBusEndpointHosting.ConsoleApp.approved.txt index e23459b1..67066d14 100644 --- a/src/Tests/ApprovalFiles/TemplateTests.NServiceBusEndpointHosting.ConsoleApp.approved.txt +++ b/src/Tests/ApprovalFiles/TemplateTests.NServiceBusEndpointHosting.ConsoleApp.approved.txt @@ -29,34 +29,31 @@ using Microsoft.Extensions.Hosting; var builder = Host.CreateApplicationBuilder(args); -builder.UseNServiceBus(() => -{ - // TODO: consider moving common endpoint configuration into a shared project - // for use by all endpoints in the system +// TODO: consider moving common endpoint configuration into a shared project +// for use by all endpoints in the system - var endpointConfiguration = new EndpointConfiguration("NServiceBusEndpointHostingConsoleApp"); +var endpointConfiguration = new EndpointConfiguration("NServiceBusEndpointHostingConsoleApp"); - // Learning Transport: https://docs.particular.net/transports/learning/ - var routing = endpointConfiguration.UseTransport(new LearningTransport()); +// Learning Transport: https://docs.particular.net/transports/learning/ +var routing = endpointConfiguration.UseTransport(new LearningTransport()); - // Define routing for commands: https://docs.particular.net/nservicebus/messaging/routing#command-routing - // routing.RouteToEndpoint(typeof(MessageType), "DestinationEndpointForType"); - // routing.RouteToEndpoint(typeof(MessageType).Assembly, "DestinationForAllCommandsInAssembly"); +// Define routing for commands: https://docs.particular.net/nservicebus/messaging/routing#command-routing +// routing.RouteToEndpoint(typeof(MessageType), "DestinationEndpointForType"); +// routing.RouteToEndpoint(typeof(MessageType).Assembly, "DestinationForAllCommandsInAssembly"); - // Learning Persistence: https://docs.particular.net/persistence/learning/ - endpointConfiguration.UsePersistence(); +// Learning Persistence: https://docs.particular.net/persistence/learning/ +endpointConfiguration.UsePersistence(); - // Message serialization - endpointConfiguration.UseSerialization(); +// Message serialization +endpointConfiguration.UseSerialization(); - endpointConfiguration.DefineCriticalErrorAction(OnCriticalError); +endpointConfiguration.DefineCriticalErrorAction(OnCriticalError); - // Installers are useful in development. Consider disabling in production. - // https://docs.particular.net/nservicebus/operations/installers - endpointConfiguration.EnableInstallers(); +// Installers are useful in development. Consider disabling in production. +// https://docs.particular.net/nservicebus/operations/installers +endpointConfiguration.EnableInstallers(); - return endpointConfiguration; -}); +builder.UseNServiceBus(endpointConfiguration); var app = builder.Build(); app.Run(); diff --git a/src/Tests/ApprovalFiles/TemplateTests.NServiceBusEndpointHosting.Docker.approved.txt b/src/Tests/ApprovalFiles/TemplateTests.NServiceBusEndpointHosting.Docker.approved.txt index 60fd6109..2d8eb2a3 100644 --- a/src/Tests/ApprovalFiles/TemplateTests.NServiceBusEndpointHosting.Docker.approved.txt +++ b/src/Tests/ApprovalFiles/TemplateTests.NServiceBusEndpointHosting.Docker.approved.txt @@ -31,34 +31,31 @@ using Microsoft.Extensions.Hosting; var builder = Host.CreateApplicationBuilder(args); -builder.UseNServiceBus(() => -{ - // TODO: consider moving common endpoint configuration into a shared project - // for use by all endpoints in the system +// TODO: consider moving common endpoint configuration into a shared project +// for use by all endpoints in the system - var endpointConfiguration = new EndpointConfiguration("NServiceBusEndpointHostingDocker"); +var endpointConfiguration = new EndpointConfiguration("NServiceBusEndpointHostingDocker"); - // Learning Transport: https://docs.particular.net/transports/learning/ - var routing = endpointConfiguration.UseTransport(new LearningTransport()); +// Learning Transport: https://docs.particular.net/transports/learning/ +var routing = endpointConfiguration.UseTransport(new LearningTransport()); - // Define routing for commands: https://docs.particular.net/nservicebus/messaging/routing#command-routing - // routing.RouteToEndpoint(typeof(MessageType), "DestinationEndpointForType"); - // routing.RouteToEndpoint(typeof(MessageType).Assembly, "DestinationForAllCommandsInAssembly"); +// Define routing for commands: https://docs.particular.net/nservicebus/messaging/routing#command-routing +// routing.RouteToEndpoint(typeof(MessageType), "DestinationEndpointForType"); +// routing.RouteToEndpoint(typeof(MessageType).Assembly, "DestinationForAllCommandsInAssembly"); - // Learning Persistence: https://docs.particular.net/persistence/learning/ - endpointConfiguration.UsePersistence(); +// Learning Persistence: https://docs.particular.net/persistence/learning/ +endpointConfiguration.UsePersistence(); - // Message serialization - endpointConfiguration.UseSerialization(); +// Message serialization +endpointConfiguration.UseSerialization(); - endpointConfiguration.DefineCriticalErrorAction(OnCriticalError); +endpointConfiguration.DefineCriticalErrorAction(OnCriticalError); - // Installers are useful in development. Consider disabling in production. - // https://docs.particular.net/nservicebus/operations/installers - endpointConfiguration.EnableInstallers(); +// Installers are useful in development. Consider disabling in production. +// https://docs.particular.net/nservicebus/operations/installers +endpointConfiguration.EnableInstallers(); - return endpointConfiguration; -}); +builder.UseNServiceBus(endpointConfiguration); var app = builder.Build(); app.Run(); diff --git a/src/Tests/ApprovalFiles/TemplateTests.NServiceBusEndpointHosting.WindowsService.approved.txt b/src/Tests/ApprovalFiles/TemplateTests.NServiceBusEndpointHosting.WindowsService.approved.txt index f2837bec..1b1acdb5 100644 --- a/src/Tests/ApprovalFiles/TemplateTests.NServiceBusEndpointHosting.WindowsService.approved.txt +++ b/src/Tests/ApprovalFiles/TemplateTests.NServiceBusEndpointHosting.WindowsService.approved.txt @@ -31,34 +31,31 @@ using Microsoft.Extensions.Hosting; var builder = Host.CreateApplicationBuilder(args); builder.Services.AddWindowsService(); -builder.UseNServiceBus(() => -{ - // TODO: consider moving common endpoint configuration into a shared project - // for use by all endpoints in the system +// TODO: consider moving common endpoint configuration into a shared project +// for use by all endpoints in the system - var endpointConfiguration = new EndpointConfiguration("NServiceBusEndpointHostingWindowsService"); +var endpointConfiguration = new EndpointConfiguration("NServiceBusEndpointHostingWindowsService"); - // Learning Transport: https://docs.particular.net/transports/learning/ - var routing = endpointConfiguration.UseTransport(new LearningTransport()); +// Learning Transport: https://docs.particular.net/transports/learning/ +var routing = endpointConfiguration.UseTransport(new LearningTransport()); - // Define routing for commands: https://docs.particular.net/nservicebus/messaging/routing#command-routing - // routing.RouteToEndpoint(typeof(MessageType), "DestinationEndpointForType"); - // routing.RouteToEndpoint(typeof(MessageType).Assembly, "DestinationForAllCommandsInAssembly"); +// Define routing for commands: https://docs.particular.net/nservicebus/messaging/routing#command-routing +// routing.RouteToEndpoint(typeof(MessageType), "DestinationEndpointForType"); +// routing.RouteToEndpoint(typeof(MessageType).Assembly, "DestinationForAllCommandsInAssembly"); - // Learning Persistence: https://docs.particular.net/persistence/learning/ - endpointConfiguration.UsePersistence(); +// Learning Persistence: https://docs.particular.net/persistence/learning/ +endpointConfiguration.UsePersistence(); - // Message serialization - endpointConfiguration.UseSerialization(); +// Message serialization +endpointConfiguration.UseSerialization(); - endpointConfiguration.DefineCriticalErrorAction(OnCriticalError); +endpointConfiguration.DefineCriticalErrorAction(OnCriticalError); - // Installers are useful in development. Consider disabling in production. - // https://docs.particular.net/nservicebus/operations/installers - endpointConfiguration.EnableInstallers(); +// Installers are useful in development. Consider disabling in production. +// https://docs.particular.net/nservicebus/operations/installers +endpointConfiguration.EnableInstallers(); - return endpointConfiguration; -}); +builder.UseNServiceBus(endpointConfiguration); var app = builder.Build(); app.Run(); diff --git a/src/Tests/ApprovalFiles/TemplateTests.NServiceBusEndpointPersistence.AzureTable.approved.txt b/src/Tests/ApprovalFiles/TemplateTests.NServiceBusEndpointPersistence.AzureTable.approved.txt index 314c7457..3d05dd33 100644 --- a/src/Tests/ApprovalFiles/TemplateTests.NServiceBusEndpointPersistence.AzureTable.approved.txt +++ b/src/Tests/ApprovalFiles/TemplateTests.NServiceBusEndpointPersistence.AzureTable.approved.txt @@ -30,35 +30,32 @@ using Microsoft.Extensions.Hosting; var builder = Host.CreateApplicationBuilder(args); -builder.UseNServiceBus(() => -{ - // TODO: consider moving common endpoint configuration into a shared project - // for use by all endpoints in the system +// TODO: consider moving common endpoint configuration into a shared project +// for use by all endpoints in the system - var endpointConfiguration = new EndpointConfiguration("NServiceBusEndpointPersistenceAzureTable"); +var endpointConfiguration = new EndpointConfiguration("NServiceBusEndpointPersistenceAzureTable"); - // Learning Transport: https://docs.particular.net/transports/learning/ - var routing = endpointConfiguration.UseTransport(new LearningTransport()); +// Learning Transport: https://docs.particular.net/transports/learning/ +var routing = endpointConfiguration.UseTransport(new LearningTransport()); - // Define routing for commands: https://docs.particular.net/nservicebus/messaging/routing#command-routing - // routing.RouteToEndpoint(typeof(MessageType), "DestinationEndpointForType"); - // routing.RouteToEndpoint(typeof(MessageType).Assembly, "DestinationForAllCommandsInAssembly"); +// Define routing for commands: https://docs.particular.net/nservicebus/messaging/routing#command-routing +// routing.RouteToEndpoint(typeof(MessageType), "DestinationEndpointForType"); +// routing.RouteToEndpoint(typeof(MessageType).Assembly, "DestinationForAllCommandsInAssembly"); - // Azure Table Persistence: https://docs.particular.net/persistence/azure-table/ - var persistence = endpointConfiguration.UsePersistence(); - persistence.ConnectionString("DefaultEndpointsProtocol=https;AccountName=[ACCOUNT];AccountKey=[KEY];"); +// Azure Table Persistence: https://docs.particular.net/persistence/azure-table/ +var persistence = endpointConfiguration.UsePersistence(); +persistence.ConnectionString("DefaultEndpointsProtocol=https;AccountName=[ACCOUNT];AccountKey=[KEY];"); - // Message serialization - endpointConfiguration.UseSerialization(); +// Message serialization +endpointConfiguration.UseSerialization(); - endpointConfiguration.DefineCriticalErrorAction(OnCriticalError); +endpointConfiguration.DefineCriticalErrorAction(OnCriticalError); - // Installers are useful in development. Consider disabling in production. - // https://docs.particular.net/nservicebus/operations/installers - endpointConfiguration.EnableInstallers(); +// Installers are useful in development. Consider disabling in production. +// https://docs.particular.net/nservicebus/operations/installers +endpointConfiguration.EnableInstallers(); - return endpointConfiguration; -}); +builder.UseNServiceBus(endpointConfiguration); var app = builder.Build(); app.Run(); diff --git a/src/Tests/ApprovalFiles/TemplateTests.NServiceBusEndpointPersistence.CosmosDB.approved.txt b/src/Tests/ApprovalFiles/TemplateTests.NServiceBusEndpointPersistence.CosmosDB.approved.txt index 45efce26..6203ceaf 100644 --- a/src/Tests/ApprovalFiles/TemplateTests.NServiceBusEndpointPersistence.CosmosDB.approved.txt +++ b/src/Tests/ApprovalFiles/TemplateTests.NServiceBusEndpointPersistence.CosmosDB.approved.txt @@ -31,36 +31,33 @@ using Microsoft.Extensions.Hosting; var builder = Host.CreateApplicationBuilder(args); -builder.UseNServiceBus(() => -{ - // TODO: consider moving common endpoint configuration into a shared project - // for use by all endpoints in the system +// TODO: consider moving common endpoint configuration into a shared project +// for use by all endpoints in the system - var endpointConfiguration = new EndpointConfiguration("NServiceBusEndpointPersistenceCosmosDB"); +var endpointConfiguration = new EndpointConfiguration("NServiceBusEndpointPersistenceCosmosDB"); - // Learning Transport: https://docs.particular.net/transports/learning/ - var routing = endpointConfiguration.UseTransport(new LearningTransport()); +// Learning Transport: https://docs.particular.net/transports/learning/ +var routing = endpointConfiguration.UseTransport(new LearningTransport()); - // Define routing for commands: https://docs.particular.net/nservicebus/messaging/routing#command-routing - // routing.RouteToEndpoint(typeof(MessageType), "DestinationEndpointForType"); - // routing.RouteToEndpoint(typeof(MessageType).Assembly, "DestinationForAllCommandsInAssembly"); +// Define routing for commands: https://docs.particular.net/nservicebus/messaging/routing#command-routing +// routing.RouteToEndpoint(typeof(MessageType), "DestinationEndpointForType"); +// routing.RouteToEndpoint(typeof(MessageType).Assembly, "DestinationForAllCommandsInAssembly"); - // Cosmos DB Persistence: https://docs.particular.net/persistence/cosmosdb/ - var persistence = endpointConfiguration.UsePersistence(); - persistence.CosmosClient(new CosmosClient("CONNECTION_STRING")); - persistence.DatabaseName("DATABASE_NAME"); +// Cosmos DB Persistence: https://docs.particular.net/persistence/cosmosdb/ +var persistence = endpointConfiguration.UsePersistence(); +persistence.CosmosClient(new CosmosClient("CONNECTION_STRING")); +persistence.DatabaseName("DATABASE_NAME"); - // Message serialization - endpointConfiguration.UseSerialization(); +// Message serialization +endpointConfiguration.UseSerialization(); - endpointConfiguration.DefineCriticalErrorAction(OnCriticalError); +endpointConfiguration.DefineCriticalErrorAction(OnCriticalError); - // Installers are useful in development. Consider disabling in production. - // https://docs.particular.net/nservicebus/operations/installers - endpointConfiguration.EnableInstallers(); +// Installers are useful in development. Consider disabling in production. +// https://docs.particular.net/nservicebus/operations/installers +endpointConfiguration.EnableInstallers(); - return endpointConfiguration; -}); +builder.UseNServiceBus(endpointConfiguration); var app = builder.Build(); app.Run(); diff --git a/src/Tests/ApprovalFiles/TemplateTests.NServiceBusEndpointPersistence.DynamoDB.approved.txt b/src/Tests/ApprovalFiles/TemplateTests.NServiceBusEndpointPersistence.DynamoDB.approved.txt index debe5279..2f835f70 100644 --- a/src/Tests/ApprovalFiles/TemplateTests.NServiceBusEndpointPersistence.DynamoDB.approved.txt +++ b/src/Tests/ApprovalFiles/TemplateTests.NServiceBusEndpointPersistence.DynamoDB.approved.txt @@ -30,34 +30,31 @@ using Microsoft.Extensions.Hosting; var builder = Host.CreateApplicationBuilder(args); -builder.UseNServiceBus(() => -{ - // TODO: consider moving common endpoint configuration into a shared project - // for use by all endpoints in the system +// TODO: consider moving common endpoint configuration into a shared project +// for use by all endpoints in the system - var endpointConfiguration = new EndpointConfiguration("NServiceBusEndpointPersistenceDynamoDB"); +var endpointConfiguration = new EndpointConfiguration("NServiceBusEndpointPersistenceDynamoDB"); - // Learning Transport: https://docs.particular.net/transports/learning/ - var routing = endpointConfiguration.UseTransport(new LearningTransport()); +// Learning Transport: https://docs.particular.net/transports/learning/ +var routing = endpointConfiguration.UseTransport(new LearningTransport()); - // Define routing for commands: https://docs.particular.net/nservicebus/messaging/routing#command-routing - // routing.RouteToEndpoint(typeof(MessageType), "DestinationEndpointForType"); - // routing.RouteToEndpoint(typeof(MessageType).Assembly, "DestinationForAllCommandsInAssembly"); +// Define routing for commands: https://docs.particular.net/nservicebus/messaging/routing#command-routing +// routing.RouteToEndpoint(typeof(MessageType), "DestinationEndpointForType"); +// routing.RouteToEndpoint(typeof(MessageType).Assembly, "DestinationForAllCommandsInAssembly"); - // Amazon DynamoDB Persistence: https://docs.particular.net/persistence/dynamodb/ - var persistence = endpointConfiguration.UsePersistence(); +// Amazon DynamoDB Persistence: https://docs.particular.net/persistence/dynamodb/ +var persistence = endpointConfiguration.UsePersistence(); - // Message serialization - endpointConfiguration.UseSerialization(); +// Message serialization +endpointConfiguration.UseSerialization(); - endpointConfiguration.DefineCriticalErrorAction(OnCriticalError); +endpointConfiguration.DefineCriticalErrorAction(OnCriticalError); - // Installers are useful in development. Consider disabling in production. - // https://docs.particular.net/nservicebus/operations/installers - endpointConfiguration.EnableInstallers(); +// Installers are useful in development. Consider disabling in production. +// https://docs.particular.net/nservicebus/operations/installers +endpointConfiguration.EnableInstallers(); - return endpointConfiguration; -}); +builder.UseNServiceBus(endpointConfiguration); var app = builder.Build(); app.Run(); diff --git a/src/Tests/ApprovalFiles/TemplateTests.NServiceBusEndpointPersistence.LearningPersistence.approved.txt b/src/Tests/ApprovalFiles/TemplateTests.NServiceBusEndpointPersistence.LearningPersistence.approved.txt index 10d7956d..6e3b1bf7 100644 --- a/src/Tests/ApprovalFiles/TemplateTests.NServiceBusEndpointPersistence.LearningPersistence.approved.txt +++ b/src/Tests/ApprovalFiles/TemplateTests.NServiceBusEndpointPersistence.LearningPersistence.approved.txt @@ -29,34 +29,31 @@ using Microsoft.Extensions.Hosting; var builder = Host.CreateApplicationBuilder(args); -builder.UseNServiceBus(() => -{ - // TODO: consider moving common endpoint configuration into a shared project - // for use by all endpoints in the system +// TODO: consider moving common endpoint configuration into a shared project +// for use by all endpoints in the system - var endpointConfiguration = new EndpointConfiguration("NServiceBusEndpointPersistenceLearningPersistence"); +var endpointConfiguration = new EndpointConfiguration("NServiceBusEndpointPersistenceLearningPersistence"); - // Learning Transport: https://docs.particular.net/transports/learning/ - var routing = endpointConfiguration.UseTransport(new LearningTransport()); +// Learning Transport: https://docs.particular.net/transports/learning/ +var routing = endpointConfiguration.UseTransport(new LearningTransport()); - // Define routing for commands: https://docs.particular.net/nservicebus/messaging/routing#command-routing - // routing.RouteToEndpoint(typeof(MessageType), "DestinationEndpointForType"); - // routing.RouteToEndpoint(typeof(MessageType).Assembly, "DestinationForAllCommandsInAssembly"); +// Define routing for commands: https://docs.particular.net/nservicebus/messaging/routing#command-routing +// routing.RouteToEndpoint(typeof(MessageType), "DestinationEndpointForType"); +// routing.RouteToEndpoint(typeof(MessageType).Assembly, "DestinationForAllCommandsInAssembly"); - // Learning Persistence: https://docs.particular.net/persistence/learning/ - endpointConfiguration.UsePersistence(); +// Learning Persistence: https://docs.particular.net/persistence/learning/ +endpointConfiguration.UsePersistence(); - // Message serialization - endpointConfiguration.UseSerialization(); +// Message serialization +endpointConfiguration.UseSerialization(); - endpointConfiguration.DefineCriticalErrorAction(OnCriticalError); +endpointConfiguration.DefineCriticalErrorAction(OnCriticalError); - // Installers are useful in development. Consider disabling in production. - // https://docs.particular.net/nservicebus/operations/installers - endpointConfiguration.EnableInstallers(); +// Installers are useful in development. Consider disabling in production. +// https://docs.particular.net/nservicebus/operations/installers +endpointConfiguration.EnableInstallers(); - return endpointConfiguration; -}); +builder.UseNServiceBus(endpointConfiguration); var app = builder.Build(); app.Run(); diff --git a/src/Tests/ApprovalFiles/TemplateTests.NServiceBusEndpointPersistence.MSSQL.approved.txt b/src/Tests/ApprovalFiles/TemplateTests.NServiceBusEndpointPersistence.MSSQL.approved.txt index cfc7e90b..c2b77e17 100644 --- a/src/Tests/ApprovalFiles/TemplateTests.NServiceBusEndpointPersistence.MSSQL.approved.txt +++ b/src/Tests/ApprovalFiles/TemplateTests.NServiceBusEndpointPersistence.MSSQL.approved.txt @@ -32,38 +32,35 @@ using Microsoft.Extensions.Hosting; var builder = Host.CreateApplicationBuilder(args); -builder.UseNServiceBus(() => -{ - // TODO: consider moving common endpoint configuration into a shared project - // for use by all endpoints in the system +// TODO: consider moving common endpoint configuration into a shared project +// for use by all endpoints in the system - var endpointConfiguration = new EndpointConfiguration("NServiceBusEndpointPersistenceMSSQL"); +var endpointConfiguration = new EndpointConfiguration("NServiceBusEndpointPersistenceMSSQL"); - // Learning Transport: https://docs.particular.net/transports/learning/ - var routing = endpointConfiguration.UseTransport(new LearningTransport()); +// Learning Transport: https://docs.particular.net/transports/learning/ +var routing = endpointConfiguration.UseTransport(new LearningTransport()); - // Define routing for commands: https://docs.particular.net/nservicebus/messaging/routing#command-routing - // routing.RouteToEndpoint(typeof(MessageType), "DestinationEndpointForType"); - // routing.RouteToEndpoint(typeof(MessageType).Assembly, "DestinationForAllCommandsInAssembly"); +// Define routing for commands: https://docs.particular.net/nservicebus/messaging/routing#command-routing +// routing.RouteToEndpoint(typeof(MessageType), "DestinationEndpointForType"); +// routing.RouteToEndpoint(typeof(MessageType).Assembly, "DestinationForAllCommandsInAssembly"); - // SQL Persistence: https://docs.particular.net/persistence/sql/ - // Microsoft SQL Server dialect: https://docs.particular.net/persistence/sql/dialect-mssql - var dbConnectionString = "Data Source=.\\SqlExpress;Initial Catalog=dbname;Integrated Security=True;"; - var persistence = endpointConfiguration.UsePersistence(); - persistence.SqlDialect(); - persistence.ConnectionBuilder(() => new SqlConnection(dbConnectionString)); +// SQL Persistence: https://docs.particular.net/persistence/sql/ +// Microsoft SQL Server dialect: https://docs.particular.net/persistence/sql/dialect-mssql +var dbConnectionString = "Data Source=.\\SqlExpress;Initial Catalog=dbname;Integrated Security=True;"; +var persistence = endpointConfiguration.UsePersistence(); +persistence.SqlDialect(); +persistence.ConnectionBuilder(() => new SqlConnection(dbConnectionString)); - // Message serialization - endpointConfiguration.UseSerialization(); +// Message serialization +endpointConfiguration.UseSerialization(); - endpointConfiguration.DefineCriticalErrorAction(OnCriticalError); +endpointConfiguration.DefineCriticalErrorAction(OnCriticalError); - // Installers are useful in development. Consider disabling in production. - // https://docs.particular.net/nservicebus/operations/installers - endpointConfiguration.EnableInstallers(); +// Installers are useful in development. Consider disabling in production. +// https://docs.particular.net/nservicebus/operations/installers +endpointConfiguration.EnableInstallers(); - return endpointConfiguration; -}); +builder.UseNServiceBus(endpointConfiguration); var app = builder.Build(); app.Run(); diff --git a/src/Tests/ApprovalFiles/TemplateTests.NServiceBusEndpointPersistence.MongoDB.approved.txt b/src/Tests/ApprovalFiles/TemplateTests.NServiceBusEndpointPersistence.MongoDB.approved.txt index fe34f811..9355adad 100644 --- a/src/Tests/ApprovalFiles/TemplateTests.NServiceBusEndpointPersistence.MongoDB.approved.txt +++ b/src/Tests/ApprovalFiles/TemplateTests.NServiceBusEndpointPersistence.MongoDB.approved.txt @@ -30,35 +30,32 @@ using Microsoft.Extensions.Hosting; var builder = Host.CreateApplicationBuilder(args); -builder.UseNServiceBus(() => -{ - // TODO: consider moving common endpoint configuration into a shared project - // for use by all endpoints in the system +// TODO: consider moving common endpoint configuration into a shared project +// for use by all endpoints in the system - var endpointConfiguration = new EndpointConfiguration("NServiceBusEndpointPersistenceMongoDB"); +var endpointConfiguration = new EndpointConfiguration("NServiceBusEndpointPersistenceMongoDB"); - // Learning Transport: https://docs.particular.net/transports/learning/ - var routing = endpointConfiguration.UseTransport(new LearningTransport()); +// Learning Transport: https://docs.particular.net/transports/learning/ +var routing = endpointConfiguration.UseTransport(new LearningTransport()); - // Define routing for commands: https://docs.particular.net/nservicebus/messaging/routing#command-routing - // routing.RouteToEndpoint(typeof(MessageType), "DestinationEndpointForType"); - // routing.RouteToEndpoint(typeof(MessageType).Assembly, "DestinationForAllCommandsInAssembly"); +// Define routing for commands: https://docs.particular.net/nservicebus/messaging/routing#command-routing +// routing.RouteToEndpoint(typeof(MessageType), "DestinationEndpointForType"); +// routing.RouteToEndpoint(typeof(MessageType).Assembly, "DestinationForAllCommandsInAssembly"); - // MongoDB Persistence: https://docs.particular.net/persistence/mongodb/ - var persistence = endpointConfiguration.UsePersistence(); - persistence.DatabaseName("DATABASE_NAME"); +// MongoDB Persistence: https://docs.particular.net/persistence/mongodb/ +var persistence = endpointConfiguration.UsePersistence(); +persistence.DatabaseName("DATABASE_NAME"); - // Message serialization - endpointConfiguration.UseSerialization(); +// Message serialization +endpointConfiguration.UseSerialization(); - endpointConfiguration.DefineCriticalErrorAction(OnCriticalError); +endpointConfiguration.DefineCriticalErrorAction(OnCriticalError); - // Installers are useful in development. Consider disabling in production. - // https://docs.particular.net/nservicebus/operations/installers - endpointConfiguration.EnableInstallers(); +// Installers are useful in development. Consider disabling in production. +// https://docs.particular.net/nservicebus/operations/installers +endpointConfiguration.EnableInstallers(); - return endpointConfiguration; -}); +builder.UseNServiceBus(endpointConfiguration); var app = builder.Build(); app.Run(); diff --git a/src/Tests/ApprovalFiles/TemplateTests.NServiceBusEndpointPersistence.MySQL.approved.txt b/src/Tests/ApprovalFiles/TemplateTests.NServiceBusEndpointPersistence.MySQL.approved.txt index 7dbd2ddf..72c3d728 100644 --- a/src/Tests/ApprovalFiles/TemplateTests.NServiceBusEndpointPersistence.MySQL.approved.txt +++ b/src/Tests/ApprovalFiles/TemplateTests.NServiceBusEndpointPersistence.MySQL.approved.txt @@ -32,38 +32,35 @@ using MySql.Data.MySqlClient; var builder = Host.CreateApplicationBuilder(args); -builder.UseNServiceBus(() => -{ - // TODO: consider moving common endpoint configuration into a shared project - // for use by all endpoints in the system +// TODO: consider moving common endpoint configuration into a shared project +// for use by all endpoints in the system - var endpointConfiguration = new EndpointConfiguration("NServiceBusEndpointPersistenceMySQL"); +var endpointConfiguration = new EndpointConfiguration("NServiceBusEndpointPersistenceMySQL"); - // Learning Transport: https://docs.particular.net/transports/learning/ - var routing = endpointConfiguration.UseTransport(new LearningTransport()); +// Learning Transport: https://docs.particular.net/transports/learning/ +var routing = endpointConfiguration.UseTransport(new LearningTransport()); - // Define routing for commands: https://docs.particular.net/nservicebus/messaging/routing#command-routing - // routing.RouteToEndpoint(typeof(MessageType), "DestinationEndpointForType"); - // routing.RouteToEndpoint(typeof(MessageType).Assembly, "DestinationForAllCommandsInAssembly"); +// Define routing for commands: https://docs.particular.net/nservicebus/messaging/routing#command-routing +// routing.RouteToEndpoint(typeof(MessageType), "DestinationEndpointForType"); +// routing.RouteToEndpoint(typeof(MessageType).Assembly, "DestinationForAllCommandsInAssembly"); - // SQL Persistence: https://docs.particular.net/persistence/sql/ - // MySQL dialect: https://docs.particular.net/persistence/sql/dialect-mysql - var dbConnectionString = "server=localhost;user=root;database=dbname;port=3306;password=pass;AllowUserVariables=True;AutoEnlist=false"; - var persistence = endpointConfiguration.UsePersistence(); - persistence.SqlDialect(); - persistence.ConnectionBuilder(() => new MySqlConnection(dbConnectionString)); +// SQL Persistence: https://docs.particular.net/persistence/sql/ +// MySQL dialect: https://docs.particular.net/persistence/sql/dialect-mysql +var dbConnectionString = "server=localhost;user=root;database=dbname;port=3306;password=pass;AllowUserVariables=True;AutoEnlist=false"; +var persistence = endpointConfiguration.UsePersistence(); +persistence.SqlDialect(); +persistence.ConnectionBuilder(() => new MySqlConnection(dbConnectionString)); - // Message serialization - endpointConfiguration.UseSerialization(); +// Message serialization +endpointConfiguration.UseSerialization(); - endpointConfiguration.DefineCriticalErrorAction(OnCriticalError); +endpointConfiguration.DefineCriticalErrorAction(OnCriticalError); - // Installers are useful in development. Consider disabling in production. - // https://docs.particular.net/nservicebus/operations/installers - endpointConfiguration.EnableInstallers(); +// Installers are useful in development. Consider disabling in production. +// https://docs.particular.net/nservicebus/operations/installers +endpointConfiguration.EnableInstallers(); - return endpointConfiguration; -}); +builder.UseNServiceBus(endpointConfiguration); var app = builder.Build(); app.Run(); diff --git a/src/Tests/ApprovalFiles/TemplateTests.NServiceBusEndpointPersistence.Oracle.approved.txt b/src/Tests/ApprovalFiles/TemplateTests.NServiceBusEndpointPersistence.Oracle.approved.txt index 63cf4643..e1e0c31a 100644 --- a/src/Tests/ApprovalFiles/TemplateTests.NServiceBusEndpointPersistence.Oracle.approved.txt +++ b/src/Tests/ApprovalFiles/TemplateTests.NServiceBusEndpointPersistence.Oracle.approved.txt @@ -32,38 +32,35 @@ using Oracle.ManagedDataAccess.Client; var builder = Host.CreateApplicationBuilder(args); -builder.UseNServiceBus(() => -{ - // TODO: consider moving common endpoint configuration into a shared project - // for use by all endpoints in the system +// TODO: consider moving common endpoint configuration into a shared project +// for use by all endpoints in the system - var endpointConfiguration = new EndpointConfiguration("NServiceBusEndpointPersistenceOracle"); +var endpointConfiguration = new EndpointConfiguration("NServiceBusEndpointPersistenceOracle"); - // Learning Transport: https://docs.particular.net/transports/learning/ - var routing = endpointConfiguration.UseTransport(new LearningTransport()); +// Learning Transport: https://docs.particular.net/transports/learning/ +var routing = endpointConfiguration.UseTransport(new LearningTransport()); - // Define routing for commands: https://docs.particular.net/nservicebus/messaging/routing#command-routing - // routing.RouteToEndpoint(typeof(MessageType), "DestinationEndpointForType"); - // routing.RouteToEndpoint(typeof(MessageType).Assembly, "DestinationForAllCommandsInAssembly"); +// Define routing for commands: https://docs.particular.net/nservicebus/messaging/routing#command-routing +// routing.RouteToEndpoint(typeof(MessageType), "DestinationEndpointForType"); +// routing.RouteToEndpoint(typeof(MessageType).Assembly, "DestinationForAllCommandsInAssembly"); - // SQL Persistence: https://docs.particular.net/persistence/sql/ - // Oracle dialect: https://docs.particular.net/persistence/sql/dialect-oracle - var dbConnectionString = "Data Source=localhost;User Id=username;Password=pass;Enlist=false;"; - var persistence = endpointConfiguration.UsePersistence(); - persistence.SqlDialect(); - persistence.ConnectionBuilder(() => new OracleConnection(dbConnectionString)); +// SQL Persistence: https://docs.particular.net/persistence/sql/ +// Oracle dialect: https://docs.particular.net/persistence/sql/dialect-oracle +var dbConnectionString = "Data Source=localhost;User Id=username;Password=pass;Enlist=false;"; +var persistence = endpointConfiguration.UsePersistence(); +persistence.SqlDialect(); +persistence.ConnectionBuilder(() => new OracleConnection(dbConnectionString)); - // Message serialization - endpointConfiguration.UseSerialization(); +// Message serialization +endpointConfiguration.UseSerialization(); - endpointConfiguration.DefineCriticalErrorAction(OnCriticalError); +endpointConfiguration.DefineCriticalErrorAction(OnCriticalError); - // Installers are useful in development. Consider disabling in production. - // https://docs.particular.net/nservicebus/operations/installers - endpointConfiguration.EnableInstallers(); +// Installers are useful in development. Consider disabling in production. +// https://docs.particular.net/nservicebus/operations/installers +endpointConfiguration.EnableInstallers(); - return endpointConfiguration; -}); +builder.UseNServiceBus(endpointConfiguration); var app = builder.Build(); app.Run(); diff --git a/src/Tests/ApprovalFiles/TemplateTests.NServiceBusEndpointPersistence.PostgreSQL.approved.txt b/src/Tests/ApprovalFiles/TemplateTests.NServiceBusEndpointPersistence.PostgreSQL.approved.txt index 49ff6e8b..024f4d4b 100644 --- a/src/Tests/ApprovalFiles/TemplateTests.NServiceBusEndpointPersistence.PostgreSQL.approved.txt +++ b/src/Tests/ApprovalFiles/TemplateTests.NServiceBusEndpointPersistence.PostgreSQL.approved.txt @@ -33,43 +33,40 @@ using NpgsqlTypes; var builder = Host.CreateApplicationBuilder(args); -builder.UseNServiceBus(() => -{ - // TODO: consider moving common endpoint configuration into a shared project - // for use by all endpoints in the system +// TODO: consider moving common endpoint configuration into a shared project +// for use by all endpoints in the system - var endpointConfiguration = new EndpointConfiguration("NServiceBusEndpointPersistencePostgreSQL"); +var endpointConfiguration = new EndpointConfiguration("NServiceBusEndpointPersistencePostgreSQL"); - // Learning Transport: https://docs.particular.net/transports/learning/ - var routing = endpointConfiguration.UseTransport(new LearningTransport()); +// Learning Transport: https://docs.particular.net/transports/learning/ +var routing = endpointConfiguration.UseTransport(new LearningTransport()); - // Define routing for commands: https://docs.particular.net/nservicebus/messaging/routing#command-routing - // routing.RouteToEndpoint(typeof(MessageType), "DestinationEndpointForType"); - // routing.RouteToEndpoint(typeof(MessageType).Assembly, "DestinationForAllCommandsInAssembly"); +// Define routing for commands: https://docs.particular.net/nservicebus/messaging/routing#command-routing +// routing.RouteToEndpoint(typeof(MessageType), "DestinationEndpointForType"); +// routing.RouteToEndpoint(typeof(MessageType).Assembly, "DestinationForAllCommandsInAssembly"); - // SQL Persistence: https://docs.particular.net/persistence/sql/ - // PostgreSQL dialect: https://docs.particular.net/persistence/sql/dialect-postgresql - var dbConnectionString = "Server=localhost;Port=5432;Database=dbname;User Id=user;Password=pass;"; - var persistence = endpointConfiguration.UsePersistence(); - var dialect = persistence.SqlDialect(); - dialect.JsonBParameterModifier(parameter => - { - var npgsqlParameter = (NpgsqlParameter)parameter; - npgsqlParameter.NpgsqlDbType = NpgsqlDbType.Jsonb; - }); - persistence.ConnectionBuilder(() => new NpgsqlConnection(dbConnectionString)); +// SQL Persistence: https://docs.particular.net/persistence/sql/ +// PostgreSQL dialect: https://docs.particular.net/persistence/sql/dialect-postgresql +var dbConnectionString = "Server=localhost;Port=5432;Database=dbname;User Id=user;Password=pass;"; +var persistence = endpointConfiguration.UsePersistence(); +var dialect = persistence.SqlDialect(); +dialect.JsonBParameterModifier(parameter => +{ + var npgsqlParameter = (NpgsqlParameter)parameter; + npgsqlParameter.NpgsqlDbType = NpgsqlDbType.Jsonb; +}); +persistence.ConnectionBuilder(() => new NpgsqlConnection(dbConnectionString)); - // Message serialization - endpointConfiguration.UseSerialization(); +// Message serialization +endpointConfiguration.UseSerialization(); - endpointConfiguration.DefineCriticalErrorAction(OnCriticalError); +endpointConfiguration.DefineCriticalErrorAction(OnCriticalError); - // Installers are useful in development. Consider disabling in production. - // https://docs.particular.net/nservicebus/operations/installers - endpointConfiguration.EnableInstallers(); +// Installers are useful in development. Consider disabling in production. +// https://docs.particular.net/nservicebus/operations/installers +endpointConfiguration.EnableInstallers(); - return endpointConfiguration; -}); +builder.UseNServiceBus(endpointConfiguration); var app = builder.Build(); app.Run(); diff --git a/src/Tests/ApprovalFiles/TemplateTests.NServiceBusEndpointPersistence.RavenDB.approved.txt b/src/Tests/ApprovalFiles/TemplateTests.NServiceBusEndpointPersistence.RavenDB.approved.txt index 52efa50b..b5e67739 100644 --- a/src/Tests/ApprovalFiles/TemplateTests.NServiceBusEndpointPersistence.RavenDB.approved.txt +++ b/src/Tests/ApprovalFiles/TemplateTests.NServiceBusEndpointPersistence.RavenDB.approved.txt @@ -31,44 +31,41 @@ using Raven.Client.Documents; var builder = Host.CreateApplicationBuilder(args); -builder.UseNServiceBus(() => -{ - // TODO: consider moving common endpoint configuration into a shared project - // for use by all endpoints in the system +// TODO: consider moving common endpoint configuration into a shared project +// for use by all endpoints in the system - var endpointConfiguration = new EndpointConfiguration("NServiceBusEndpointPersistenceRavenDB"); +var endpointConfiguration = new EndpointConfiguration("NServiceBusEndpointPersistenceRavenDB"); - // Learning Transport: https://docs.particular.net/transports/learning/ - var routing = endpointConfiguration.UseTransport(new LearningTransport()); +// Learning Transport: https://docs.particular.net/transports/learning/ +var routing = endpointConfiguration.UseTransport(new LearningTransport()); - // Define routing for commands: https://docs.particular.net/nservicebus/messaging/routing#command-routing - // routing.RouteToEndpoint(typeof(MessageType), "DestinationEndpointForType"); - // routing.RouteToEndpoint(typeof(MessageType).Assembly, "DestinationForAllCommandsInAssembly"); +// Define routing for commands: https://docs.particular.net/nservicebus/messaging/routing#command-routing +// routing.RouteToEndpoint(typeof(MessageType), "DestinationEndpointForType"); +// routing.RouteToEndpoint(typeof(MessageType).Assembly, "DestinationForAllCommandsInAssembly"); - // RavenDB Persistence: https://docs.particular.net/persistence/ravendb/ - DocumentStore documentStore; - var persistence = endpointConfiguration.UsePersistence(); - persistence.SetDefaultDocumentStore(readOnlySettings => +// RavenDB Persistence: https://docs.particular.net/persistence/ravendb/ +DocumentStore documentStore; +var persistence = endpointConfiguration.UsePersistence(); +persistence.SetDefaultDocumentStore(readOnlySettings => +{ + documentStore = new DocumentStore { - documentStore = new DocumentStore - { - Urls = new[] { "http://localhost:8080" }, - Database = readOnlySettings.EndpointName() - }; - return documentStore; - }); + Urls = new[] { "http://localhost:8080" }, + Database = readOnlySettings.EndpointName() + }; + return documentStore; +}); - // Message serialization - endpointConfiguration.UseSerialization(); +// Message serialization +endpointConfiguration.UseSerialization(); - endpointConfiguration.DefineCriticalErrorAction(OnCriticalError); +endpointConfiguration.DefineCriticalErrorAction(OnCriticalError); - // Installers are useful in development. Consider disabling in production. - // https://docs.particular.net/nservicebus/operations/installers - endpointConfiguration.EnableInstallers(); +// Installers are useful in development. Consider disabling in production. +// https://docs.particular.net/nservicebus/operations/installers +endpointConfiguration.EnableInstallers(); - return endpointConfiguration; -}); +builder.UseNServiceBus(endpointConfiguration); var app = builder.Build(); app.Run(); diff --git a/src/Tests/ApprovalFiles/TemplateTests.NServiceBusEndpointTargetFramework.net8.0.approved.txt b/src/Tests/ApprovalFiles/TemplateTests.NServiceBusEndpointTargetFramework.net8.0.approved.txt index ea941aa6..daf44a08 100644 --- a/src/Tests/ApprovalFiles/TemplateTests.NServiceBusEndpointTargetFramework.net8.0.approved.txt +++ b/src/Tests/ApprovalFiles/TemplateTests.NServiceBusEndpointTargetFramework.net8.0.approved.txt @@ -29,34 +29,31 @@ using Microsoft.Extensions.Hosting; var builder = Host.CreateApplicationBuilder(args); -builder.UseNServiceBus(() => -{ - // TODO: consider moving common endpoint configuration into a shared project - // for use by all endpoints in the system +// TODO: consider moving common endpoint configuration into a shared project +// for use by all endpoints in the system - var endpointConfiguration = new EndpointConfiguration("NServiceBusEndpointTargetFrameworknet8._0"); +var endpointConfiguration = new EndpointConfiguration("NServiceBusEndpointTargetFrameworknet8._0"); - // Learning Transport: https://docs.particular.net/transports/learning/ - var routing = endpointConfiguration.UseTransport(new LearningTransport()); +// Learning Transport: https://docs.particular.net/transports/learning/ +var routing = endpointConfiguration.UseTransport(new LearningTransport()); - // Define routing for commands: https://docs.particular.net/nservicebus/messaging/routing#command-routing - // routing.RouteToEndpoint(typeof(MessageType), "DestinationEndpointForType"); - // routing.RouteToEndpoint(typeof(MessageType).Assembly, "DestinationForAllCommandsInAssembly"); +// Define routing for commands: https://docs.particular.net/nservicebus/messaging/routing#command-routing +// routing.RouteToEndpoint(typeof(MessageType), "DestinationEndpointForType"); +// routing.RouteToEndpoint(typeof(MessageType).Assembly, "DestinationForAllCommandsInAssembly"); - // Learning Persistence: https://docs.particular.net/persistence/learning/ - endpointConfiguration.UsePersistence(); +// Learning Persistence: https://docs.particular.net/persistence/learning/ +endpointConfiguration.UsePersistence(); - // Message serialization - endpointConfiguration.UseSerialization(); +// Message serialization +endpointConfiguration.UseSerialization(); - endpointConfiguration.DefineCriticalErrorAction(OnCriticalError); +endpointConfiguration.DefineCriticalErrorAction(OnCriticalError); - // Installers are useful in development. Consider disabling in production. - // https://docs.particular.net/nservicebus/operations/installers - endpointConfiguration.EnableInstallers(); +// Installers are useful in development. Consider disabling in production. +// https://docs.particular.net/nservicebus/operations/installers +endpointConfiguration.EnableInstallers(); - return endpointConfiguration; -}); +builder.UseNServiceBus(endpointConfiguration); var app = builder.Build(); app.Run(); diff --git a/src/Tests/ApprovalFiles/TemplateTests.NServiceBusEndpointTransports.AzureServiceBus.approved.txt b/src/Tests/ApprovalFiles/TemplateTests.NServiceBusEndpointTransports.AzureServiceBus.approved.txt index ac6def2a..51283025 100644 --- a/src/Tests/ApprovalFiles/TemplateTests.NServiceBusEndpointTransports.AzureServiceBus.approved.txt +++ b/src/Tests/ApprovalFiles/TemplateTests.NServiceBusEndpointTransports.AzureServiceBus.approved.txt @@ -30,35 +30,32 @@ using Microsoft.Extensions.Hosting; var builder = Host.CreateApplicationBuilder(args); -builder.UseNServiceBus(() => -{ - // TODO: consider moving common endpoint configuration into a shared project - // for use by all endpoints in the system +// TODO: consider moving common endpoint configuration into a shared project +// for use by all endpoints in the system - var endpointConfiguration = new EndpointConfiguration("NServiceBusEndpointTransportsAzureServiceBus"); +var endpointConfiguration = new EndpointConfiguration("NServiceBusEndpointTransportsAzureServiceBus"); - // Azure Service Bus Transport: https://docs.particular.net/transports/azure-service-bus/ - var transport = new AzureServiceBusTransport("CONNECTION_STRING"); - var routing = endpointConfiguration.UseTransport(transport); +// Azure Service Bus Transport: https://docs.particular.net/transports/azure-service-bus/ +var transport = new AzureServiceBusTransport("CONNECTION_STRING"); +var routing = endpointConfiguration.UseTransport(transport); - // Define routing for commands: https://docs.particular.net/nservicebus/messaging/routing#command-routing - // routing.RouteToEndpoint(typeof(MessageType), "DestinationEndpointForType"); - // routing.RouteToEndpoint(typeof(MessageType).Assembly, "DestinationForAllCommandsInAssembly"); +// Define routing for commands: https://docs.particular.net/nservicebus/messaging/routing#command-routing +// routing.RouteToEndpoint(typeof(MessageType), "DestinationEndpointForType"); +// routing.RouteToEndpoint(typeof(MessageType).Assembly, "DestinationForAllCommandsInAssembly"); - // Learning Persistence: https://docs.particular.net/persistence/learning/ - endpointConfiguration.UsePersistence(); +// Learning Persistence: https://docs.particular.net/persistence/learning/ +endpointConfiguration.UsePersistence(); - // Message serialization - endpointConfiguration.UseSerialization(); +// Message serialization +endpointConfiguration.UseSerialization(); - endpointConfiguration.DefineCriticalErrorAction(OnCriticalError); +endpointConfiguration.DefineCriticalErrorAction(OnCriticalError); - // Installers are useful in development. Consider disabling in production. - // https://docs.particular.net/nservicebus/operations/installers - endpointConfiguration.EnableInstallers(); +// Installers are useful in development. Consider disabling in production. +// https://docs.particular.net/nservicebus/operations/installers +endpointConfiguration.EnableInstallers(); - return endpointConfiguration; -}); +builder.UseNServiceBus(endpointConfiguration); var app = builder.Build(); app.Run(); diff --git a/src/Tests/ApprovalFiles/TemplateTests.NServiceBusEndpointTransports.AzureStorageQueues.approved.txt b/src/Tests/ApprovalFiles/TemplateTests.NServiceBusEndpointTransports.AzureStorageQueues.approved.txt index 04513d98..166fd218 100644 --- a/src/Tests/ApprovalFiles/TemplateTests.NServiceBusEndpointTransports.AzureStorageQueues.approved.txt +++ b/src/Tests/ApprovalFiles/TemplateTests.NServiceBusEndpointTransports.AzureStorageQueues.approved.txt @@ -30,35 +30,32 @@ using Microsoft.Extensions.Hosting; var builder = Host.CreateApplicationBuilder(args); -builder.UseNServiceBus(() => -{ - // TODO: consider moving common endpoint configuration into a shared project - // for use by all endpoints in the system +// TODO: consider moving common endpoint configuration into a shared project +// for use by all endpoints in the system - var endpointConfiguration = new EndpointConfiguration("NServiceBusEndpointTransportsAzureStorageQueues"); +var endpointConfiguration = new EndpointConfiguration("NServiceBusEndpointTransportsAzureStorageQueues"); - // Azure Storage Queues Transport: https://docs.particular.net/transports/azure-storage-queues/ - var transport = new AzureStorageQueueTransport("DefaultEndpointsProtocol=https;AccountName=[ACCOUNT];AccountKey=[KEY];"); - var routing = endpointConfiguration.UseTransport(transport); +// Azure Storage Queues Transport: https://docs.particular.net/transports/azure-storage-queues/ +var transport = new AzureStorageQueueTransport("DefaultEndpointsProtocol=https;AccountName=[ACCOUNT];AccountKey=[KEY];"); +var routing = endpointConfiguration.UseTransport(transport); - // Define routing for commands: https://docs.particular.net/nservicebus/messaging/routing#command-routing - // routing.RouteToEndpoint(typeof(MessageType), "DestinationEndpointForType"); - // routing.RouteToEndpoint(typeof(MessageType).Assembly, "DestinationForAllCommandsInAssembly"); +// Define routing for commands: https://docs.particular.net/nservicebus/messaging/routing#command-routing +// routing.RouteToEndpoint(typeof(MessageType), "DestinationEndpointForType"); +// routing.RouteToEndpoint(typeof(MessageType).Assembly, "DestinationForAllCommandsInAssembly"); - // Learning Persistence: https://docs.particular.net/persistence/learning/ - endpointConfiguration.UsePersistence(); +// Learning Persistence: https://docs.particular.net/persistence/learning/ +endpointConfiguration.UsePersistence(); - // Message serialization - endpointConfiguration.UseSerialization(); +// Message serialization +endpointConfiguration.UseSerialization(); - endpointConfiguration.DefineCriticalErrorAction(OnCriticalError); +endpointConfiguration.DefineCriticalErrorAction(OnCriticalError); - // Installers are useful in development. Consider disabling in production. - // https://docs.particular.net/nservicebus/operations/installers - endpointConfiguration.EnableInstallers(); +// Installers are useful in development. Consider disabling in production. +// https://docs.particular.net/nservicebus/operations/installers +endpointConfiguration.EnableInstallers(); - return endpointConfiguration; -}); +builder.UseNServiceBus(endpointConfiguration); var app = builder.Build(); app.Run(); diff --git a/src/Tests/ApprovalFiles/TemplateTests.NServiceBusEndpointTransports.LearningTransport.approved.txt b/src/Tests/ApprovalFiles/TemplateTests.NServiceBusEndpointTransports.LearningTransport.approved.txt index 7d7d70b1..397051ff 100644 --- a/src/Tests/ApprovalFiles/TemplateTests.NServiceBusEndpointTransports.LearningTransport.approved.txt +++ b/src/Tests/ApprovalFiles/TemplateTests.NServiceBusEndpointTransports.LearningTransport.approved.txt @@ -29,34 +29,31 @@ using Microsoft.Extensions.Hosting; var builder = Host.CreateApplicationBuilder(args); -builder.UseNServiceBus(() => -{ - // TODO: consider moving common endpoint configuration into a shared project - // for use by all endpoints in the system +// TODO: consider moving common endpoint configuration into a shared project +// for use by all endpoints in the system - var endpointConfiguration = new EndpointConfiguration("NServiceBusEndpointTransportsLearningTransport"); +var endpointConfiguration = new EndpointConfiguration("NServiceBusEndpointTransportsLearningTransport"); - // Learning Transport: https://docs.particular.net/transports/learning/ - var routing = endpointConfiguration.UseTransport(new LearningTransport()); +// Learning Transport: https://docs.particular.net/transports/learning/ +var routing = endpointConfiguration.UseTransport(new LearningTransport()); - // Define routing for commands: https://docs.particular.net/nservicebus/messaging/routing#command-routing - // routing.RouteToEndpoint(typeof(MessageType), "DestinationEndpointForType"); - // routing.RouteToEndpoint(typeof(MessageType).Assembly, "DestinationForAllCommandsInAssembly"); +// Define routing for commands: https://docs.particular.net/nservicebus/messaging/routing#command-routing +// routing.RouteToEndpoint(typeof(MessageType), "DestinationEndpointForType"); +// routing.RouteToEndpoint(typeof(MessageType).Assembly, "DestinationForAllCommandsInAssembly"); - // Learning Persistence: https://docs.particular.net/persistence/learning/ - endpointConfiguration.UsePersistence(); +// Learning Persistence: https://docs.particular.net/persistence/learning/ +endpointConfiguration.UsePersistence(); - // Message serialization - endpointConfiguration.UseSerialization(); +// Message serialization +endpointConfiguration.UseSerialization(); - endpointConfiguration.DefineCriticalErrorAction(OnCriticalError); +endpointConfiguration.DefineCriticalErrorAction(OnCriticalError); - // Installers are useful in development. Consider disabling in production. - // https://docs.particular.net/nservicebus/operations/installers - endpointConfiguration.EnableInstallers(); +// Installers are useful in development. Consider disabling in production. +// https://docs.particular.net/nservicebus/operations/installers +endpointConfiguration.EnableInstallers(); - return endpointConfiguration; -}); +builder.UseNServiceBus(endpointConfiguration); var app = builder.Build(); app.Run(); diff --git a/src/Tests/ApprovalFiles/TemplateTests.NServiceBusEndpointTransports.RabbitMQ.approved.txt b/src/Tests/ApprovalFiles/TemplateTests.NServiceBusEndpointTransports.RabbitMQ.approved.txt index d80169a0..6f2cf87f 100644 --- a/src/Tests/ApprovalFiles/TemplateTests.NServiceBusEndpointTransports.RabbitMQ.approved.txt +++ b/src/Tests/ApprovalFiles/TemplateTests.NServiceBusEndpointTransports.RabbitMQ.approved.txt @@ -30,36 +30,33 @@ using Microsoft.Extensions.Hosting; var builder = Host.CreateApplicationBuilder(args); -builder.UseNServiceBus(() => -{ - // TODO: consider moving common endpoint configuration into a shared project - // for use by all endpoints in the system +// TODO: consider moving common endpoint configuration into a shared project +// for use by all endpoints in the system - var endpointConfiguration = new EndpointConfiguration("NServiceBusEndpointTransportsRabbitMQ"); +var endpointConfiguration = new EndpointConfiguration("NServiceBusEndpointTransportsRabbitMQ"); - // RabbitMQ Transport: https://docs.particular.net/transports/rabbitmq/ - var rabbitMqConnectionString = "CONNECTION_STRING"; - var transport = new RabbitMQTransport(RoutingTopology.Conventional(QueueType.Quorum), rabbitMqConnectionString); - var routing = endpointConfiguration.UseTransport(transport); +// RabbitMQ Transport: https://docs.particular.net/transports/rabbitmq/ +var rabbitMqConnectionString = "CONNECTION_STRING"; +var transport = new RabbitMQTransport(RoutingTopology.Conventional(QueueType.Quorum), rabbitMqConnectionString); +var routing = endpointConfiguration.UseTransport(transport); - // Define routing for commands: https://docs.particular.net/nservicebus/messaging/routing#command-routing - // routing.RouteToEndpoint(typeof(MessageType), "DestinationEndpointForType"); - // routing.RouteToEndpoint(typeof(MessageType).Assembly, "DestinationForAllCommandsInAssembly"); +// Define routing for commands: https://docs.particular.net/nservicebus/messaging/routing#command-routing +// routing.RouteToEndpoint(typeof(MessageType), "DestinationEndpointForType"); +// routing.RouteToEndpoint(typeof(MessageType).Assembly, "DestinationForAllCommandsInAssembly"); - // Learning Persistence: https://docs.particular.net/persistence/learning/ - endpointConfiguration.UsePersistence(); +// Learning Persistence: https://docs.particular.net/persistence/learning/ +endpointConfiguration.UsePersistence(); - // Message serialization - endpointConfiguration.UseSerialization(); +// Message serialization +endpointConfiguration.UseSerialization(); - endpointConfiguration.DefineCriticalErrorAction(OnCriticalError); +endpointConfiguration.DefineCriticalErrorAction(OnCriticalError); - // Installers are useful in development. Consider disabling in production. - // https://docs.particular.net/nservicebus/operations/installers - endpointConfiguration.EnableInstallers(); +// Installers are useful in development. Consider disabling in production. +// https://docs.particular.net/nservicebus/operations/installers +endpointConfiguration.EnableInstallers(); - return endpointConfiguration; -}); +builder.UseNServiceBus(endpointConfiguration); var app = builder.Build(); app.Run(); diff --git a/src/Tests/ApprovalFiles/TemplateTests.NServiceBusEndpointTransports.SQL.approved.txt b/src/Tests/ApprovalFiles/TemplateTests.NServiceBusEndpointTransports.SQL.approved.txt index 651f4aae..861ea3c7 100644 --- a/src/Tests/ApprovalFiles/TemplateTests.NServiceBusEndpointTransports.SQL.approved.txt +++ b/src/Tests/ApprovalFiles/TemplateTests.NServiceBusEndpointTransports.SQL.approved.txt @@ -30,35 +30,32 @@ using Microsoft.Extensions.Hosting; var builder = Host.CreateApplicationBuilder(args); -builder.UseNServiceBus(() => -{ - // TODO: consider moving common endpoint configuration into a shared project - // for use by all endpoints in the system +// TODO: consider moving common endpoint configuration into a shared project +// for use by all endpoints in the system - var endpointConfiguration = new EndpointConfiguration("NServiceBusEndpointTransportsSQL"); +var endpointConfiguration = new EndpointConfiguration("NServiceBusEndpointTransportsSQL"); - // SQL Server Transport: https://docs.particular.net/transports/sql/ - var transport = new SqlServerTransport("Data Source=.\\SqlExpress;Initial Catalog=dbname;Integrated Security=True"); - var routing = endpointConfiguration.UseTransport(transport); +// SQL Server Transport: https://docs.particular.net/transports/sql/ +var transport = new SqlServerTransport("Data Source=.\\SqlExpress;Initial Catalog=dbname;Integrated Security=True"); +var routing = endpointConfiguration.UseTransport(transport); - // Define routing for commands: https://docs.particular.net/nservicebus/messaging/routing#command-routing - // routing.RouteToEndpoint(typeof(MessageType), "DestinationEndpointForType"); - // routing.RouteToEndpoint(typeof(MessageType).Assembly, "DestinationForAllCommandsInAssembly"); +// Define routing for commands: https://docs.particular.net/nservicebus/messaging/routing#command-routing +// routing.RouteToEndpoint(typeof(MessageType), "DestinationEndpointForType"); +// routing.RouteToEndpoint(typeof(MessageType).Assembly, "DestinationForAllCommandsInAssembly"); - // Learning Persistence: https://docs.particular.net/persistence/learning/ - endpointConfiguration.UsePersistence(); +// Learning Persistence: https://docs.particular.net/persistence/learning/ +endpointConfiguration.UsePersistence(); - // Message serialization - endpointConfiguration.UseSerialization(); +// Message serialization +endpointConfiguration.UseSerialization(); - endpointConfiguration.DefineCriticalErrorAction(OnCriticalError); +endpointConfiguration.DefineCriticalErrorAction(OnCriticalError); - // Installers are useful in development. Consider disabling in production. - // https://docs.particular.net/nservicebus/operations/installers - endpointConfiguration.EnableInstallers(); +// Installers are useful in development. Consider disabling in production. +// https://docs.particular.net/nservicebus/operations/installers +endpointConfiguration.EnableInstallers(); - return endpointConfiguration; -}); +builder.UseNServiceBus(endpointConfiguration); var app = builder.Build(); app.Run(); diff --git a/src/Tests/ApprovalFiles/TemplateTests.NServiceBusEndpointTransports.SQS.approved.txt b/src/Tests/ApprovalFiles/TemplateTests.NServiceBusEndpointTransports.SQS.approved.txt index f1afe82b..d8b150e9 100644 --- a/src/Tests/ApprovalFiles/TemplateTests.NServiceBusEndpointTransports.SQS.approved.txt +++ b/src/Tests/ApprovalFiles/TemplateTests.NServiceBusEndpointTransports.SQS.approved.txt @@ -30,35 +30,32 @@ using Microsoft.Extensions.Hosting; var builder = Host.CreateApplicationBuilder(args); -builder.UseNServiceBus(() => -{ - // TODO: consider moving common endpoint configuration into a shared project - // for use by all endpoints in the system +// TODO: consider moving common endpoint configuration into a shared project +// for use by all endpoints in the system - var endpointConfiguration = new EndpointConfiguration("NServiceBusEndpointTransportsSQS"); +var endpointConfiguration = new EndpointConfiguration("NServiceBusEndpointTransportsSQS"); - // Amazon SQS Transport: https://docs.particular.net/transports/sqs/ - var transport = new SqsTransport(); - var routing = endpointConfiguration.UseTransport(transport); +// Amazon SQS Transport: https://docs.particular.net/transports/sqs/ +var transport = new SqsTransport(); +var routing = endpointConfiguration.UseTransport(transport); - // Define routing for commands: https://docs.particular.net/nservicebus/messaging/routing#command-routing - // routing.RouteToEndpoint(typeof(MessageType), "DestinationEndpointForType"); - // routing.RouteToEndpoint(typeof(MessageType).Assembly, "DestinationForAllCommandsInAssembly"); +// Define routing for commands: https://docs.particular.net/nservicebus/messaging/routing#command-routing +// routing.RouteToEndpoint(typeof(MessageType), "DestinationEndpointForType"); +// routing.RouteToEndpoint(typeof(MessageType).Assembly, "DestinationForAllCommandsInAssembly"); - // Learning Persistence: https://docs.particular.net/persistence/learning/ - endpointConfiguration.UsePersistence(); +// Learning Persistence: https://docs.particular.net/persistence/learning/ +endpointConfiguration.UsePersistence(); - // Message serialization - endpointConfiguration.UseSerialization(); +// Message serialization +endpointConfiguration.UseSerialization(); - endpointConfiguration.DefineCriticalErrorAction(OnCriticalError); +endpointConfiguration.DefineCriticalErrorAction(OnCriticalError); - // Installers are useful in development. Consider disabling in production. - // https://docs.particular.net/nservicebus/operations/installers - endpointConfiguration.EnableInstallers(); +// Installers are useful in development. Consider disabling in production. +// https://docs.particular.net/nservicebus/operations/installers +endpointConfiguration.EnableInstallers(); - return endpointConfiguration; -}); +builder.UseNServiceBus(endpointConfiguration); var app = builder.Build(); app.Run();