test: Add multi-transport MassTransit container integration tests (#3519)

New MassTransitTestApp exercises three transports in a single container test:
- Kafka Rider: validates Topic destination type and correct topic names
- RabbitMQ: validates Queue publish/send/consume through MassTransit filter
- InMemory MultiBus: validates loopback:// URI parsing via DI-registered bus

Also updates existing MassTransit integration test regex to accommodate
the parser change from underscore-split names to full path segments, and
adds unit tests for fallback address and Rider prefix detection (49 total).

Author: tippmar-nr

tests/Agent/IntegrationTests/ContainerApplications/MassTransitTestApp/Consumers.cs

@@ -0,0 +1,56 @@
+// Copyright 2020 New Relic, Inc. All rights reserved.
+// SPDX-License-Identifier: Apache-2.0
+
+using System.Threading.Tasks;
+using MassTransit;
+using Microsoft.Extensions.Logging;
+
+namespace MassTransitTestApp;
+
+public class KafkaMessageConsumer : IConsumer<KafkaMessage>
+{
+    private readonly ILogger<KafkaMessageConsumer> _logger;
+
+    public KafkaMessageConsumer(ILogger<KafkaMessageConsumer> logger)
+    {
+        _logger = logger;
+    }
+
+    public Task Consume(ConsumeContext<KafkaMessage> context)
+    {
+        _logger.LogInformation("Kafka consumed: {Text}", context.Message.Text);
+        return Task.CompletedTask;
+    }
+}
+
+public class RabbitMqMessageConsumer : IConsumer<RabbitMqMessage>
+{
+    private readonly ILogger<RabbitMqMessageConsumer> _logger;
+
+    public RabbitMqMessageConsumer(ILogger<RabbitMqMessageConsumer> logger)
+    {
+        _logger = logger;
+    }
+
+    public Task Consume(ConsumeContext<RabbitMqMessage> context)
+    {
+        _logger.LogInformation("RabbitMQ consumed: {Text}", context.Message.Text);
+        return Task.CompletedTask;
+    }
+}
+
+public class InMemoryMessageConsumer : IConsumer<InMemoryMessage>
+{
+    private readonly ILogger<InMemoryMessageConsumer> _logger;
+
+    public InMemoryMessageConsumer(ILogger<InMemoryMessageConsumer> logger)
+    {
+        _logger = logger;
+    }
+
+    public Task Consume(ConsumeContext<InMemoryMessage> context)
+    {
+        _logger.LogInformation("InMemory consumed: {Text}", context.Message.Text);
+        return Task.CompletedTask;
+    }
+}

tests/Agent/IntegrationTests/ContainerApplications/MassTransitTestApp/Controllers/InMemoryController.cs

@@ -0,0 +1,32 @@
+// Copyright 2020 New Relic, Inc. All rights reserved.
+// SPDX-License-Identifier: Apache-2.0
+
+using System;
+using System.Threading.Tasks;
+using Microsoft.AspNetCore.Mvc;
+using Microsoft.Extensions.Logging;
+
+namespace MassTransitTestApp.Controllers;
+
+[ApiController]
+[Route("inmemory")]
+public class InMemoryController : ControllerBase
+{
+    private readonly ILogger<InMemoryController> _logger;
+    private readonly IInMemoryBus _bus;
+
+    public InMemoryController(ILogger<InMemoryController> logger, IInMemoryBus bus)
+    {
+        _logger = logger;
+        _bus = bus;
+    }
+
+    [HttpGet("publish")]
+    public async Task<string> Publish()
+    {
+        var message = new InMemoryMessage { Text = $"inmem-{Guid.NewGuid():N}" };
+        await _bus.Publish(message);
+        _logger.LogInformation("InMemory published: {Text}", message.Text);
+        return "Complete";
+    }
+}

tests/Agent/IntegrationTests/ContainerApplications/MassTransitTestApp/Controllers/KafkaController.cs

@@ -0,0 +1,36 @@
+// Copyright 2020 New Relic, Inc. All rights reserved.
+// SPDX-License-Identifier: Apache-2.0
+
+using System;
+using System.Threading.Tasks;
+using MassTransit;
+using Microsoft.AspNetCore.Mvc;
+using Microsoft.Extensions.Logging;
+
+namespace MassTransitTestApp.Controllers;
+
+[ApiController]
+[Route("kafka")]
+public class KafkaController : ControllerBase
+{
+    private readonly ILogger<KafkaController> _logger;
+    private readonly ITopicProducer<KafkaMessage> _producer;
+
+    public KafkaController(ILogger<KafkaController> logger, ITopicProducer<KafkaMessage> producer)
+    {
+        _logger = logger;
+        _producer = producer;
+    }
+
+    [HttpGet("produce")]
+    public async Task<string> Produce()
+    {
+        var message = new KafkaMessage { Text = $"kafka-{Guid.NewGuid():N}" };
+        await _producer.Produce(message);
+        _logger.LogInformation("Kafka produced: {Text}", message.Text);
+        return "Complete";
+    }
+
+    [HttpGet("bootstrap_server")]
+    public string GetBootstrapServer() => Program.GetKafkaBootstrapServer();
+}

tests/Agent/IntegrationTests/ContainerApplications/MassTransitTestApp/Controllers/RabbitMqController.cs

@@ -0,0 +1,44 @@
+// Copyright 2020 New Relic, Inc. All rights reserved.
+// SPDX-License-Identifier: Apache-2.0
+
+using System;
+using System.Threading.Tasks;
+using MassTransit;
+using Microsoft.AspNetCore.Mvc;
+using Microsoft.Extensions.Logging;
+
+namespace MassTransitTestApp.Controllers;
+
+[ApiController]
+[Route("rabbitmq")]
+public class RabbitMqController : ControllerBase
+{
+    private readonly ILogger<RabbitMqController> _logger;
+    private readonly IBus _bus;
+
+    public RabbitMqController(ILogger<RabbitMqController> logger, IBus bus)
+    {
+        _logger = logger;
+        _bus = bus;
+    }
+
+    [HttpGet("publish")]
+    public async Task<string> Publish()
+    {
+        var message = new RabbitMqMessage { Text = $"rmq-pub-{Guid.NewGuid():N}" };
+        await _bus.Publish(message);
+        _logger.LogInformation("RabbitMQ published: {Text}", message.Text);
+        return "Complete";
+    }
+
+    [HttpGet("send")]
+    public async Task<string> Send()
+    {
+        var queueName = Program.GetRabbitMqQueueName();
+        var endpoint = await _bus.GetSendEndpoint(new Uri($"queue:{queueName}"));
+        var message = new RabbitMqMessage { Text = $"rmq-send-{Guid.NewGuid():N}" };
+        await endpoint.Send(message);
+        _logger.LogInformation("RabbitMQ sent: {Text}", message.Text);
+        return "Complete";
+    }
+}

tests/Agent/IntegrationTests/ContainerApplications/MassTransitTestApp/Dockerfile

@@ -0,0 +1,45 @@
+ARG DOTNET_VERSION
+ARG BUILD_ARCH
+FROM --platform=amd64 mcr.microsoft.com/dotnet/aspnet:${DOTNET_VERSION} AS base
+WORKDIR /app
+EXPOSE 80
+
+# build arch may be different from target arch (i.e., when running locally with QEMU)
+ARG DOTNET_VERSION
+ARG BUILD_ARCH
+FROM --platform=${BUILD_ARCH} mcr.microsoft.com/dotnet/sdk:${DOTNET_VERSION} AS build
+
+WORKDIR /src
+COPY ["MassTransitTestApp/MassTransitTestApp.csproj", "MassTransitTestApp/"]
+ARG APP_DOTNET_VERSION
+RUN dotnet restore "MassTransitTestApp/MassTransitTestApp.csproj" -p:TargetFramework=net${APP_DOTNET_VERSION} -p:TargetFrameworks=net${APP_DOTNET_VERSION} --runtime linux-x64
+
+COPY . .
+WORKDIR "/src/MassTransitTestApp"
+RUN dotnet build "MassTransitTestApp.csproj" -c Release -o /app/build --self-contained --framework net${APP_DOTNET_VERSION} -p:TargetFramework=net${APP_DOTNET_VERSION} -p:TargetFrameworks=net${APP_DOTNET_VERSION} --runtime linux-x64 --no-restore
+
+
+FROM build AS publish
+ARG APP_DOTNET_VERSION
+RUN dotnet publish "MassTransitTestApp.csproj" -c Release -o /app/publish --self-contained --framework net${APP_DOTNET_VERSION} -p:TargetFramework=net${APP_DOTNET_VERSION} -p:TargetFrameworks=net${APP_DOTNET_VERSION} --runtime linux-x64 --no-restore
+
+FROM base AS final
+
+# Enable the agent
+ARG NEW_RELIC_HOST
+ARG NEW_RELIC_LICENSE_KEY
+ARG NEW_RELIC_APP_NAME
+
+ENV CORECLR_ENABLE_PROFILING=1 \
+CORECLR_PROFILER={36032161-FFC0-4B61-B559-F6C5D41BAE5A} \
+CORECLR_NEW_RELIC_HOME=/usr/local/newrelic-dotnet-agent \
+CORECLR_PROFILER_PATH=/usr/local/newrelic-dotnet-agent/libNewRelicProfiler.so \
+NEW_RELIC_HOST=${NEW_RELIC_HOST} \
+NEW_RELIC_LICENSE_KEY=${NEW_RELIC_LICENSE_KEY} \
+NEW_RELIC_APP_NAME=${NEW_RELIC_APP_NAME} \
+NEW_RELIC_LOG_DIRECTORY=/app/logs
+
+WORKDIR /app
+COPY --from=publish /app/publish .
+
+ENTRYPOINT ["dotnet", "MassTransitTestApp.dll"]

tests/Agent/IntegrationTests/ContainerApplications/MassTransitTestApp/IInMemoryBus.cs

@@ -0,0 +1,14 @@
+// Copyright 2020 New Relic, Inc. All rights reserved.
+// SPDX-License-Identifier: Apache-2.0
+
+using MassTransit;
+
+namespace MassTransitTestApp;
+
+/// <summary>
+/// Marker interface for the InMemory MultiBus instance.
+/// MassTransit MultiBus requires a unique interface per additional bus.
+/// </summary>
+public interface IInMemoryBus : IBus
+{
+}

tests/Agent/IntegrationTests/ContainerApplications/MassTransitTestApp/MassTransitTestApp.csproj

@@ -0,0 +1,20 @@
+<Project Sdk="Microsoft.NET.Sdk.Web">
+  <PropertyGroup>
+    <TargetFrameworks>net8.0;net10.0</TargetFrameworks>
+    <DockerDefaultTargetOS>Linux</DockerDefaultTargetOS>
+    <DockerfileContext>.</DockerfileContext>
+  </PropertyGroup>
+  <!-- net8.0: older MassTransit version -->
+  <ItemGroup Condition="'$(TargetFramework)' == 'net8.0'">
+    <PackageReference Include="MassTransit.Kafka" Version="8.1.3" />
+    <PackageReference Include="MassTransit.RabbitMQ" Version="8.1.3" />
+  </ItemGroup>
+  <!-- net10.0: latest free MassTransit version -->
+  <ItemGroup Condition="'$(TargetFramework)' == 'net10.0'">
+    <PackageReference Include="MassTransit.Kafka" Version="8.5.8" />
+    <PackageReference Include="MassTransit.RabbitMQ" Version="8.5.8" />
+  </ItemGroup>
+  <ItemGroup>
+    <PackageReference Include="NewRelic.Agent.Api" Version="10.50.0" />
+  </ItemGroup>
+</Project>

tests/Agent/IntegrationTests/ContainerApplications/MassTransitTestApp/Messages.cs

@@ -0,0 +1,22 @@
+// Copyright 2020 New Relic, Inc. All rights reserved.
+// SPDX-License-Identifier: Apache-2.0
+
+namespace MassTransitTestApp;
+
+/// <summary>Message type for Kafka Rider transport.</summary>
+public class KafkaMessage
+{
+    public string Text { get; set; }
+}
+
+/// <summary>Message type for RabbitMQ bus transport.</summary>
+public class RabbitMqMessage
+{
+    public string Text { get; set; }
+}
+
+/// <summary>Message type for InMemory bus transport.</summary>
+public class InMemoryMessage
+{
+    public string Text { get; set; }
+}