Masstransit:无法使用来自 Azure 服务总线的消息

问题描述 投票:0回答:1

最近我发现了 Masstransit 包并决定尝试一下,但我有点卡住了。 我正在尝试使用预定义的订阅来订阅预定义的 ASB 主题。

我有一个主题,名称如下:

另外,我创建了以下订阅:

这是我的公共交通配置:

builder.Services.AddMassTransit(provider =>
{
    provider.AddConsumer<UpdateEmployeeConsumer>();

    provider.UsingAzureServiceBus((context, config) =>
    {
        config.Host(serviceBusConnectionString);

        config.UseConsumeFilter<MessageLoggingFilter>(context);

        config.SubscriptionEndpoint(
            "search-service",
            "employee-changed",
            endpoint =>
            {
                endpoint.ConcurrentMessageLimit = 1;

                endpoint.UseConsumeFilter<CustomerDataPropagationFilter<UpdateEmployeeMessage>>(context);
                endpoint.ConfigureConsumer<UpdateEmployeeConsumer>(context);
            }
        );
    });
});

当我运行该服务时,消息未被使用,我看到“总线停止:{service bus url}”消息。 这是日志:

masstransit
1个回答
0
投票

猜测,没有足够的日志数据来真正知道,连接到 Azure 服务总线的凭据无效(或权限不足)。

如果您配置了一个

StartTimeout
和可能的事件
WaitUntilStarted
,该过程将等待直到建立连接或阻止服务启动。配置在文档中。

© www.soinside.com 2019 - 2024. All rights reserved.