最近我发现了 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);
}
);
});
});
猜测,没有足够的日志数据来真正知道,连接到 Azure 服务总线的凭据无效(或权限不足)。
如果您配置了一个
StartTimeout
和可能的事件WaitUntilStarted
,该过程将等待直到建立连接或阻止服务启动。配置在文档中。