azureservicebus - 无法使用 Azure 服务总线和 rebus 进行发布订阅

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);

？