无法通过 Azure 服务总线和重新总线工作进行发布订阅

Question

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 的主题。并且订阅者的处理程序从未收到消息（当我启动生产者时我有订阅者运行）。

你能告诉我我做错了什么吗？

Answer 1

如果您找到了 Rebus 创建的主题，那么您的代码一定比您目前所展示的要多:)

你能展示一下你

await bus.Subscribe(toSomething);

你在哪里

await bus.Publish(something);

?

无法通过 Azure 服务总线和重新总线工作进行发布订阅

Couldn't get Publish subscribe with Azure service bus and rebus working

azureservicebus

rebus