Azure服务总线 - SQLFilter无法按预期方式工作

我试图运行其官方文档中提供的Azure服务总线示例https://azure.microsoft.com/en-gb/documentation/articles/service-bus-dotnet-how-to-use-topics-subscriptions/。Azure服务总线 - SQLFilter无法按预期方式工作

创建预订

namespaceManager.CreateSubscription(TopicName, "CreatedMessages", new SqlFilter(@"Type = 'Created'"));

发送消息

public void SendMessages() 
{ 
    var client = TopicClient.CreateFromConnectionString(_connectionString, TopicName); 

    for (var i = 0; i < 5; i++) 
    { 
     var message = new BrokeredMessage("TestMessage " + i); 

     if (i%2 == 0) 
      message.Properties["Type"] = "Created"; 
     else 
      message.Properties["Type"] = "All"; 

     client.Send(message); 
    } 
}

处理信息

public void ListenMessages() 
    { 
     Task.Factory.StartNew(() => SubscribeMessages("CreatedMessages")); 
    } 

    public void SubscribeMessages(string subscription) 
    { 
     var allMessagesClient = SubscriptionClient.CreateFromConnectionString(_connectionString, TopicName, subscription); 

     allMessagesClient.OnMessage(message => 
     { 
      try 
      { 
       Console.WriteLine($"** {subscription} **"); 
       Console.WriteLine("Body: " + message.GetBody<string>()); 
       Console.WriteLine("MessageID: " + message.MessageId); 
       Console.WriteLine("Message Type: " + message.Properties["Type"]); 
       Console.WriteLine(); 

       message.Complete(); 
      } 
      catch (Exception) 
      { 
       message.Abandon(); 
      } 
     }, 
     new OnMessageOptions 
     { 
      AutoComplete = false, 
      AutoRenewTimeout = TimeSpan.FromMinutes(1) 
     }); 
    }

上面的代码按预期工作。

但是，面临的问题是，'Type'属性被重命名为'MessageType'或'Name'之类的任何内容时，SQLFilter会停止工作，并且我不会再收到任何消息。

我在做什么错？

来源

2016-11-11 sppc42

难道是旧的“基于类型”和新的过滤器相互冲突？请记住，过滤器是持久的。 –

这是一个预期的行为。您创建的主题（CreatedMessages）会使用过滤器创建一次并按原样保存。即它是静态的。无论您何时决定过滤器需要更改，都应该更新您的订阅以拥有新的过滤器。

要使用新过滤器更新现有订阅，您可以查看NamespaceManager.GetRulesAsync(string, string)以获取订阅的现有规则，然后使用SubscriptionClient.RemoveRuleAsync(String)删除旧订阅。

来源

2016-11-12 16:28:49

Azure服务总线 - SQLFilter无法按预期方式工作

回答

相关问题