如何从SignalR集线器接收Topic消息

我已经成功创建了一个Azure应用程序，该应用程序将DbTransactions发送到ServiceBus Queue，然后将一个'通知消息'排队到ServiceBus Topic，以便其他客户端监视(…)所以他们可以自动接收更新)。

现在，我想用SignalR来监视&收到SubscriptionClient消息…我有测试代码，它自己工作得很好。

我发现了许多发送消息到Azure队列的例子(这很容易)。而且，我有从SubscriptionClient接收BrokeredMessage的代码。但是，我不能让SignalR连续监视我的Distribute方法。

如何让SignalR监控Topic ?

CODE BEHIND:(updated)

    public void Dequeue()
    {
        SubscriptionClient subscription = GetTopicSubscriptionClient(TOPIC_NAME, SUBSCRIPTION_NAME);
        subscription.Receive();
        BrokeredMessage message = subscription.Receive();
        if (message != null)
        {
            try
            {
                var body = message.GetBody<string>();
                var contextXml = message.Properties[PROPERTIES_CONTEXT_XML].ToString();
                var transaction = message.Properties[PROPERTIES_TRANSACTION_TYPE].ToString();
                Console.WriteLine("Body: " + body);
                Console.WriteLine("MessageID: " + message.MessageId);
                Console.WriteLine("Custom Property [Transaction]: " + transaction);
                var context = XmlSerializer.Deserialize<Person>(contextXml);
                message.Complete();
                Clients.All.distribute(context, transaction);
            }
            catch (Exception ex)
            {
                // Manage later
            }
        }
    }

客户端代码:

    // TEST: Hub - GridUpdaterHub
    var hubConnection = $.hubConnection();
    var gridUpdaterHubProxy = hubConnection.createHubProxy('gridUpdaterHub');
    gridUpdaterHubProxy.on('hello', function (message) {
        console.log(message);
    });
    // I want this automated
    gridUpdaterHubProxy.on('distribute', function (context, transaction) {
        console.log('It is working');
    });
    connection.start().done(function () {
        // This is successful
        gridUpdaterHubProxy.invoke('hello', "Hello");
    });