public void RegisterListener(IHubProxy proxy, ProcessingQueue queue)
    {
        proxy.On<Message>(this.Endpoint, m => {
            queue.Enqueue<bool>(() => TryProcessMessage(m));
        });
    }