1

我有一个 WinRT 应用程序，我正在使用适用于 Windows 8 的 Windows Azure 工具包。我有一个设置，我希望订阅的客户忽略发布到 ServiceBus 主题的消息，如果他们是发起者，或者如果消息比他们的订阅开始时更旧。

在我的 BrokeredMessage 的属性中，我添加了 2 项来涵盖这些场景：

message.Properties["Timestamp"] = DateTime.UtcNow.ToFileTime();
message.Properties["OriginatorId"] = clientId.ToString();

clientId 是一个 Guid。

订阅方如下所示：

// ti is a class that contains a Topic, Subscription and a bool as a cancel flag.

string FilterName = "NotMineNewOnly";

// Find or create the topic.
if (await Topic.ExistsAsync(DocumentId.ToString(), TokenProvider))
{
    ti.Topic = await Topic.GetAsync(DocumentId.ToString(), TokenProvider);
}
else
{
    ti.Topic = await Topic.CreateAsync(DocumentId.ToString(), TokenProvider);
}

// Find or create this client's subscription to the board.
if (await ti.Topic.Subscriptions.ExistsAsync(ClientSettings.Id.ToString()))
{
    ti.Subscription = await ti.Topic.Subscriptions.GetAsync(ClientSettings.Id.ToString());
}
else
{
    ti.Subscription = await ti.Topic.Subscriptions.AddAsync(ClientSettings.Id.ToString());
}

// Find or create the subscription filter.
if (!await ti.Subscription.Rules.ExistsAsync(FilterName))
{
    // Want to ignore messages generated by this client and ignore any that are older than Timestamp.
    await ti.Subscription.Rules.AddAsync(FilterName, sqlFilterExpression: string.Format("(OriginatorId != '{0}') AND (Timestamp > {1})", ClientSettings.Id, DateTime.UtcNow.ToFileTime()));
}

ti.CancelFlag = false;

Topics[boardId] = ti;

while (!ti.CancelFlag)
{
    BrokeredMessage message = await ti.Subscription.ReceiveAndDeleteAsync(TimeSpan.FromSeconds(30));

    if (!ti.CancelFlag && message != null)
    {
        // Everything gets here!  :(
    }

我找回了一切——所以我不确定我做错了什么。解决订阅过滤器问题的最简单方法是什么？

4

2 回答 2

14

当您创建订阅时，默认情况下您会获得“MatchAll”过滤器。在上面的代码中，您只是添加了过滤器，因此除了“MatchAll”过滤器之外还应用了它，因此所有消息都会被接收。创建订阅后，只需删除 $Default 过滤器即可解决问题。

于 2012-07-25T22:09:03.393 回答
1

排除故障的最佳方法是使用来自 Paolo Salvatori http://code.msdn.microsoft.com/windowsazure/Service-Bus-Explorer-f2abca5a的 Service Bus Explorer

他已经写了一些关于它的博客文章，例如http://windowsazurecat.com/2011/07/exploring-topics-and-queues-by-building-a-service-bus-explorer-toolpart-1/

Windows Azure SDK 1.7 确实具有内置功能，但 Service Bus Explorer Standalone 版本仍然更好，请参阅此处的比较。

http://soa-thoughts.blogspot.com.au/2012/06/visual-studio-service-bus-explorer.html

HTH您的调试...

于 2012-07-25T06:21:32.327 回答