【发布时间】:2018-08-17 09:37:13
【问题描述】:
var bus = Configure.With(adapter)
.Logging(l => l.ColoredConsole(minLevel: LogLevel.Error))
.Transport(t => t.UseAzureServiceBusAsOneWayClient(connectionString))
.Options(b => b.SimpleRetryStrategy(maxDeliveryAttempts: 1).Start();
var bus = Configure.With(adapter)
.Logging(l => l.ColoredConsole())
.Transport(t => t.UseAzureServiceBus(connectionString, "subscriber1"))
.Options(b =>
{
b.SimpleRetryStrategy(maxDeliveryAttempts: 2);
b.SetNumberOfWorkers(3);
b.SetMaxParallelism(3);
})
.Start();
第一条总线用于发布者,第二条总线用于订阅者。我预计这将创建一个名为subscriber1 的队列和一个具有消息类型的主题。
但相反,它创建了一个名为 subsciber1 的队列和一些名为 messages_azuremessage__messages 的主题。并且订阅者的处理程序从未收到消息(我在启动生产者时让订阅者运行)。
你能告诉我我做错了什么吗?
【问题讨论】:
标签: azureservicebus rebus