From ab9e526deaa5734497361a415bdd0fc27d37a0d3 Mon Sep 17 00:00:00 2001 From: Ramon Smits Date: Tue, 15 Oct 2024 15:37:07 +0200 Subject: [PATCH] =?UTF-8?q?=F0=9F=9B=A0=EF=B8=8F=20Early=20validation=20on?= =?UTF-8?q?=20if=20envvar=20`AzureServiceBus=5FConnectionString`=20is=20se?= =?UTF-8?q?t?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../ConfigureEndpointAzureServiceBusTransport.cs | 6 ++++++ .../ConfigureAzureServiceBusTransportInfrastructure.cs | 4 ++++ 2 files changed, 10 insertions(+) diff --git a/src/AcceptanceTests/ConfigureEndpointAzureServiceBusTransport.cs b/src/AcceptanceTests/ConfigureEndpointAzureServiceBusTransport.cs index 6eb49b59..13d1f7f6 100644 --- a/src/AcceptanceTests/ConfigureEndpointAzureServiceBusTransport.cs +++ b/src/AcceptanceTests/ConfigureEndpointAzureServiceBusTransport.cs @@ -13,6 +13,12 @@ public class ConfigureEndpointAzureServiceBusTransport : IConfigureEndpointTestE public Task Configure(string endpointName, EndpointConfiguration configuration, RunSettings settings, PublisherMetadata publisherMetadata) { var connectionString = Environment.GetEnvironmentVariable("AzureServiceBus_ConnectionString"); + + if (string.IsNullOrEmpty(connectionString)) + { + throw new InvalidOperationException("envvar AzureServiceBus_ConnectionString not set"); + } + var transport = new AzureServiceBusTransport(connectionString) { SubscriptionNamingConvention = name => Shorten(name), diff --git a/src/TransportTests/ConfigureAzureServiceBusTransportInfrastructure.cs b/src/TransportTests/ConfigureAzureServiceBusTransportInfrastructure.cs index 5af72116..7488f931 100644 --- a/src/TransportTests/ConfigureAzureServiceBusTransportInfrastructure.cs +++ b/src/TransportTests/ConfigureAzureServiceBusTransportInfrastructure.cs @@ -12,6 +12,10 @@ public class ConfigureAzureServiceBusTransportInfrastructure : IConfigureTranspo public TransportDefinition CreateTransportDefinition() { var connectionString = Environment.GetEnvironmentVariable("AzureServiceBus_ConnectionString"); + if (string.IsNullOrEmpty(connectionString)) + { + throw new InvalidOperationException("envvar AzureServiceBus_ConnectionString not set"); + } var transport = new AzureServiceBusTransport(connectionString) { SubscriptionNamingConvention = name =>