feat(servicebus): Add support to use a custom MsSqlContainer instance with Service Bus emulator

src/Testcontainers.ServiceBus/ServiceBusBuilder.cs

@@ -54,6 +54,28 @@ public ServiceBusBuilder WithAcceptLicenseAgreement(bool acceptLicenseAgreement)
         return WithEnvironment(AcceptLicenseAgreementEnvVar, licenseAgreement);
     }
 
+    /// <summary>
+    /// Sets the dependent MSSQL container for the Azure Service Bus Emulator.
+    /// </summary>
+    /// <remarks>
+    /// This method allows attaching an existing SQL Server container instance to the Azure Service Bus Emulator.
+    /// The containers must be in the same network to enable communication between them.
+    /// </remarks>
+    /// <param name="msSqlContainer">An existing instance of <see cref="MsSqlContainer"/> to use as the database backend.</param>
+    /// <param name="databaseNetworkAlias">The network alias that will be used to connect to the SQL Server container.</param>
+    /// <param name="saPassword">The SA password for the SQL Server container. Defaults to <see cref="MsSqlBuilder.DefaultPassword"/>.</param>
+    /// <returns>A configured instance of <see cref="ServiceBusBuilder"/>.</returns>
+    public ServiceBusBuilder WithMsSqlContainer(
+        MsSqlContainer msSqlContainer,
+        string databaseNetworkAlias,
+        string saPassword = MsSqlBuilder.DefaultPassword)
+    {
+        return Merge(DockerResourceConfiguration, new ServiceBusConfiguration(databaseContainer: msSqlContainer))
+            .DependsOn(msSqlContainer)
+            .WithEnvironment("MSSQL_SA_PASSWORD", saPassword)
+            .WithEnvironment("SQL_SERVER", databaseNetworkAlias);
+    }
+
     /// <inheritdoc />
     public override ServiceBusContainer Build()
     {

src/Testcontainers.ServiceBus/ServiceBusContainer.cs

@@ -33,8 +33,11 @@ public string GetConnectionString()
     /// <inheritdoc />
     protected override async Task UnsafeCreateAsync(CancellationToken ct = default)
     {
-        await _configuration.Networks.Single().CreateAsync(ct)
-            .ConfigureAwait(false);
+        foreach (var network in _configuration.Networks.ToArray())
+        {
+            await network.CreateAsync(ct)
+                .ConfigureAwait(false);
+        }
 
         await base.UnsafeCreateAsync(ct)
             .ConfigureAwait(false);

tests/Testcontainers.Databases.Tests/DatabasesContainerTest.cs

@@ -37,9 +37,18 @@ public static TheoryData<Type> GetContainerImplementations(bool expectDataProvid
 
         foreach (var testAssembly in testAssemblies)
         {
+            var testAssemblyName = testAssembly.Key.GetName().Name;
+
             // TODO: If a module contains multiple container implementations, it would require all container implementations to implement the interface.
             foreach (var containerType in testAssembly.Value.Where(type => type.IsAssignableTo(typeof(IContainer))))
             {
+                var typeAssemblyName = containerType.Assembly.GetName().Name;
+
+                if (!string.IsNullOrWhiteSpace(testAssemblyName) && !string.IsNullOrWhiteSpace(typeAssemblyName) && !testAssemblyName.Contains(typeAssemblyName))
+                {
+                    continue;
+                }
+
                 var hasDataProvider = testAssembly.Value.Exists(type => type.IsSubclassOf(typeof(DbProviderFactory)));
 
                 if (expectDataProvider && hasDataProvider)

tests/Testcontainers.ServiceBus.Tests/ServiceBusContainerWithCustomMsSqlTest.cs

@@ -0,0 +1,60 @@
+namespace Testcontainers.ServiceBus;
+
+public class ServiceBusContainerWithCustomMsSqlTest : IAsyncLifetime
+{
+    private static readonly INetwork Network = new NetworkBuilder().Build();
+
+    private readonly ServiceBusContainer _serviceBusContainer = new ServiceBusBuilder()
+        .WithNetwork(Network)
+        .WithAcceptLicenseAgreement(true)
+        .WithMsSqlContainer(new MsSqlBuilder()
+            .WithImage("mcr.microsoft.com/azure-sql-edge:latest")
+            .WithNetwork(Network)
+            .WithNetworkAliases("sql-server")
+            .Build(), "sql-server")
+        .Build();
+
+    public Task InitializeAsync()
+    {
+        return _serviceBusContainer.StartAsync();
+    }
+
+    public Task DisposeAsync()
+    {
+        return _serviceBusContainer.DisposeAsync().AsTask();
+    }
+
+    [Fact]
+    [Trait(nameof(DockerCli.DockerPlatform), nameof(DockerCli.DockerPlatform.Linux))]
+    public async Task ReceiveMessageReturnsSentMessage()
+    {
+        // Given
+        const string helloServiceBus = "Hello, Service Bus!";
+
+        // By default, the emulator uses the following configuration:
+        // https://learn.microsoft.com/en-us/azure/service-bus-messaging/test-locally-with-service-bus-emulator?tabs=automated-script#interact-with-the-emulator.
+
+        // Upload a custom configuration before the container starts using the
+        // `WithResourceMapping(string, string)` API or one of its overloads:
+        // `WithResourceMapping("Config.json", "/ServiceBus_Emulator/ConfigFiles/")`.
+        const string queueName = "queue.1";
+
+        var message = new ServiceBusMessage(helloServiceBus);
+
+        await using var client = new ServiceBusClient(_serviceBusContainer.GetConnectionString());
+
+        var sender = client.CreateSender(queueName);
+
+        var receiver = client.CreateReceiver(queueName);
+
+        // When
+        await sender.SendMessageAsync(message)
+            .ConfigureAwait(true);
+
+        var receivedMessage = await receiver.ReceiveMessageAsync()
+            .ConfigureAwait(true);
+
+        // Then
+        Assert.Equal(helloServiceBus, receivedMessage.Body.ToString());
+    }
+}

tests/Testcontainers.ServiceBus.Tests/Usings.cs

@@ -1,5 +1,8 @@
 global using System;
 global using System.Threading.Tasks;
 global using Azure.Messaging.ServiceBus;
+global using DotNet.Testcontainers.Builders;
 global using DotNet.Testcontainers.Commons;
+global using DotNet.Testcontainers.Networks;
+global using Testcontainers.MsSql;
 global using Xunit;