如何在禁止动态队列的ActiveMQ Artemis环境中使用MassTransit？

所在组织使用外部团队管理的ActiveMQ Artemis消息代理，要求所有队列、地址必须预先声明，禁用动态创建，仅允许使用静态队列。使用MassTransit实现状态机时，已配置ConfigureConsumeTopology = false，但切换至组织服务器发送消息时出现权限错误：

Apache.NMS.NMSSecurityException: AMQ229213: User: sample_user does not have permission='CREATE_NON_DURABLE_QUEUE' for queue f8597f00-44e0-45fe-b4f1-48ded333213c on address ActiveMQ.Advisory.TempQueue

当前MassTransit配置：

services.AddMassTransit(conf =>
{
    conf.SetKebabCaseEndpointNameFormatter();
    conf.AddActivities(typeof(SampleSagaStateMachine).Assembly);
    conf.AddSagaStateMachine<SampleSagaStateMachine, SampleSaga>(
        cfg =>
        {
            cfg.UseMessageRetry(r =>
            {
                r.Handle<DbUpdateConcurrencyException>();
                r.Handle<DbUpdateException>(y => y.InnerException is SqlException e && e.Number == 2627);
                r.Incremental(5, TimeSpan.FromSeconds(1), TimeSpan.FromSeconds(20));
            });
        }
        )
        .EntityFrameworkRepository(r =>
        {
            r.ConcurrencyMode = ConcurrencyMode.Optimistic;
            r.ExistingDbContext<SampleSagaContext>();
            r.UseSqlServer();
        })
        .Endpoint(e =>
        {
            e.ConfigureConsumeTopology = false;
            e.Name = opts.GetEndpointOrEntityNameFor(nameof(SampleSaga));
        });

    conf.UsingActiveMq((ctx, cfg) =>
    {
        cfg.EnableArtemisCompatibility();
        cfg.ConfigureEndpoints(ctx);
    });
});

凭证注入配置：

services
      .AddOptions<ActiveMqTransportOptions>()
      .Bind(config.GetSection(nameof(ActiveMqTransportOptions)));

发送消息代码：

var endpoint = await context.GetSendEndpoint(new Uri("queue:saga-queue"));
await endpoint.Send(
                new SampleEvent
                {
                    CorrelationId = context.Message.CorrelationId 
                }, default
            );

需求：如何禁用MassTransit所有队列创建、删除操作，适配静态队列场景？

要彻底阻止MassTransit创建任何队列（包括临时队列、咨询队列），需从以下维度调整配置：

1. 禁用临时队列创建 #

错误中的ActiveMQ.Advisory.TempQueue是MassTransit默认创建的临时响应队列导致的，需在传输配置中强制禁用：

conf.UsingActiveMq((ctx, cfg) =>
{
    cfg.EnableArtemisCompatibility();
    // 禁用临时队列，强制使用预定义队列处理响应
    cfg.DisableTemporaryQueues();
    cfg.AutoStart = false;
});

2. 完全关闭端点自动创建逻辑 #

除了saga端点的ConfigureConsumeTopology = false，还需明确禁用端点的自动创建开关，并手动绑定到预定义队列：

.AddSagaStateMachine<SampleSagaStateMachine, SampleSaga>(...)
.EntityFrameworkRepository(...)
.Endpoint(e =>
{
    e.ConfigureConsumeTopology = false;
    e.Name = opts.GetEndpointOrEntityNameFor(nameof(SampleSaga));
    // 禁止MassTransit尝试创建队列
    e.CreateIfMissing = false;
});

同时，避免调用ConfigureEndpoints（会自动配置所有端点并尝试创建队列），改为手动配置接收端点：

conf.UsingActiveMq((ctx, cfg) =>
{
    cfg.EnableArtemisCompatibility();
    cfg.DisableTemporaryQueues();
    cfg.AutoStart = false;

    // 手动绑定到预定义的静态队列
    cfg.ReceiveEndpoint(opts.GetEndpointOrEntityNameFor(nameof(SampleSaga)), e =>
    {
        e.ConfigureConsumeTopology = false;
        e.CreateIfMissing = false;
        // 关联saga到该端点
        e.ConfigureSaga<SampleSaga>(ctx);
    });
});

3. 禁用咨询消息（Advisory Messages） #

若仍出现ActiveMQ.Advisory相关权限问题，可在连接配置中关闭咨询消息监听：

conf.UsingActiveMq((ctx, cfg) =>
{
    cfg.EnableArtemisCompatibility();
    cfg.DisableTemporaryQueues();
    cfg.AutoStart = false;

    cfg.Host(new Uri("activemq:tcp://your-server:61616"), h =>
    {
        h.Username("sample_user");
        h.Password("your-password");
        // 禁用咨询消息监听
        h.Properties["jms.watchTopicAdvisories"] = false;
        h.Properties["jms.watchQueueAdvisories"] = false;
    });

    cfg.ReceiveEndpoint(opts.GetEndpointOrEntityNameFor(nameof(SampleSaga)), e =>
    {
        e.ConfigureConsumeTopology = false;
        e.CreateIfMissing = false;
        e.ConfigureSaga<SampleSaga>(ctx);
    });
});

4. 发送消息的注意事项 #

发送消息时直接使用预先声明的静态队列URI即可，无需额外配置，确保MassTransit不会尝试创建任何关联资源。

内容的提问来源于stack exchange，提问作者Francesco Donini