我有一个消息泵看起来像这样: public class MessagePump<T> where T : class
{
public async Task Run(string inQueue, IMessageProcessor<T> processor, CancellationToken cancellationToken)
{
var co
使用队列客户端创建辅助角色时的模板代码提供了消息泵实现。代码中有一条评论: // Initiates the message pump and callback is invoked for each message that is received, calling close on the client will stop the pump.
sourceClient.OnMessage(r
为了记录目的,我希望获得给定订阅客户端的Azure服务总线订阅的消息数。唯一的examples我发现使用NamespaceManager,但这似乎有点多余,因为我已经有一个SubscriptionClient。有没有办法直接从客户端到SubscriptionDescription? FWIW,我试图通过名字空间管理器使用的弯路,但我得到了它抛出一个401未经授权错误: int GetMessage