FastServiceBusEmulator.Aspire.Hosting 0.5.0

Fast Azure Service Bus Emulator

A high-performance, lightweight Azure Service Bus emulator for integration testing. It implements the AMQP 1.0 protocol and mocks the Azure Service Bus behavior required by official SDKs.

Usage

var builder = DistributedApplication.CreateBuilder(args);

var serviceBus = builder.AddFastServiceBusEmulator("servicebus")
    .WithTopology(new Topology
    {
        Queues = [
            new Queue("input-queue")
            {
                DeadLetteringOnMessageExpiration = true,
                LockDurationSeconds = 10,
                MaxDeliveryCount = 3,
                MaxSize = 100,
                DefaultMessageTtlSeconds = 1000
            }
        ],
        Topics = [
            new Topic("topic \"test\"")
            {
                Subscriptions = [
                    new Subscription("sub-1")
                    {
                        DeadLetteringOnMessageExpiration = true,
                        LockDurationSeconds = 10,
                        MaxDeliveryCount = 3,
                        MaxSize = 100,
                        DefaultMessageTtlSeconds = 1000,
                        Filters = [
                            new CorrelationFilter
                            {
                                ContentType = "application/json",
                                Subject = "sub-1",
                                MessageId =  "message\\1",
                                To =  "sub-2",
                                ReplyTo =  "sub-3",
                                CorrelationId =  "sub-4",
                                Properties = new Dictionary<string, string> {
                                    ["prop1"] = "value1"
                                }
                            }
                        ]
                    },
                    new Subscription("sub-2")
                ]
            },
            new Topic("events")
            {
                Subscriptions = [
                    new Subscription("sub-1")
                ]
            }
        ]
    });

builder.AddProject<FastServiceBusEmulatorTestProject>("test-project")
    .WithReference(serviceBus);

builder.Build().Run();

Endpoints

• AMQP endpoint: serviceBus.Resource.AmqpEndpoint
• Admin HTTP endpoint: serviceBus.Resource.AdminEndpoint (default container port 45672)

TestingClient

Use TestingClient with the admin endpoint to reset, inspect, and inject messages in tests.

Available methods include:

• DeleteAllMessagesAsync
• GetAllMessagesAsync
• DeleteQueueMessagesAsync / GetQueueMessagesAsync / PostQueueMessageAsync
• DeleteTopicMessagesAsync / GetTopicMessagesAsync / PostTopicMessageAsync
• DeleteSubscriptionMessagesAsync / GetSubscriptionMessagesAsync
• PostQueueMessageAsync and PostTopicMessageAsync