公共交通未收到 Azure 服务总线主题消息

本文关键字:总线 服务 消息 Azure | 更新日期: 2023-09-27 18:33:58

我正在监视主题,订阅和消息正在进入,但是我的公共交通消费者没有收到任何东西。

以下是它的设置方式:

var bus = Bus.Factory.CreateUsingAzureServiceBus(
                        cfg =>
                        {
                            var azSbHost = cfg.Host(new Uri(CloudConfigurationManager.GetSetting("ServiceBus.Url"))
                                , host =>
                                {
                                    host.TokenProvider = TokenProvider
                                        .CreateSharedAccessSignatureTokenProvider
                                        (CloudConfigurationManager.GetSetting("ServiceBus.SharedAccessKeyName"),
                                            CloudConfigurationManager.GetSetting("ServiceBus.AccessKey"),
                                            TokenScope.Namespace);                                    
                                });
                            cfg.ReceiveEndpoint(azSbHost,
                                e =>
                                {
                                    e.Consumer<PingConsumer>();
                                });
                            //azSbHost.
                        });

平消费者:

public class PingConsumer : IConsumer<Ping>
{
    public async Task Consume(ConsumeContext<Ping> pingContext)
    {
        pingContext.Respond(new Pong
        {
            Message = "Pong: " + pingContext.Message.Message
        });
    }
}

和发件人:

           var pong = await _bus.CreatePublishRequestClient<Ping, Pong>(TimeSpan.FromSeconds(10),null ).Request(
            new Ping {Message = "Ping: " + message});

在 Azure 中,我看到我的消息计数在上升而不是下降。因此,消息进入队列,但使用者没有使用消息。

公共交通未收到 Azure 服务总线主题消息

我错过了一个非常重要的关键调用,以使它在客户端和服务器端都正常工作。

巴士开始