【问题标题】:Couldn't get Publish subscribe with Azure service bus and rebus working无法使用 Azure 服务总线和 rebus 进行发布订阅
【发布时间】: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


    【解决方案1】:

    如果您发现了 Rebus 创建的主题,那么您的代码肯定比目前显示的要多:)

    你可以展示你所在的部分吗

    await bus.Subscribe(toSomething);
    

    你在哪里

    await bus.Publish(something);
    

    ?

    【讨论】:

    • 是的,你是对的。我有 bus.Subscribe().Wait();被错误注释掉的行。这就是消费者没有阅读消息的原因。非常感谢!
    猜你喜欢
    • 2018-02-26
    • 2020-06-13
    • 1970-01-01
    • 2020-07-06
    • 1970-01-01
    • 1970-01-01
    • 2020-10-08
    • 2016-04-28
    • 1970-01-01
    相关资源
    最近更新 更多