WampRealmProxyReconnector.cs

using System;
using System.Collections.Generic;
using System.Linq;
using System.Threading.Tasks;
using WampSharp.V2;
using WampSharp.V2.Client;
using WampSharp.V2.Core.Contracts;

namespace HubUSA.LPR.CameraService
{
    /// <summary>
    /// Our wrapper around reconnection logic for proxies, in order for subscribers
    /// to stay perpetually subscribed
    /// </summary>
    public class WampReconnector : IDisposable
    {
        private readonly IWampChannel _channel;
        private readonly IList<object> _subscribers;
        private readonly WampChannelReconnector _reconnector;

        /// <summary>
        /// Our wrapper around reconnection logic for proxies, in order for subscribers
        /// to stay perpetually subscribed
        /// </summary>
        public WampReconnector(
            IWampChannel channel,
            IEnumerable<object> subscribers)
        {
            _channel = channel;
            _subscribers = subscribers.ToList();
            _reconnector = new WampChannelReconnector(_channel, Reconnect);
        }

        /// <summary>
        /// Starts the reconnection implemented in wampsharp, and
        /// registers all of the subscribers within the reconnection logic
        /// </summary>
        public void Start()
        {
            _reconnector.Start();
        }

        private Task Reconnect()
        {
            _channel.Open().Wait();

            var tasks = new List<Task>();
            foreach (var subscriber in _subscribers)
            {
                tasks.Add(_channel.RealmProxy.Services.RegisterSubscriber(subscriber));
            }

            foreach (var task in tasks)
            {
                task.Wait();
            }

            return Task.FromResult(0);
        } 

        /// <summary>
        /// Performs application-defined tasks associated with freeing, releasing, or resetting unmanaged resources.
        /// </summary>
        /// <filterpriority>2</filterpriority>
        public void Dispose()
        {
            _reconnector?.Dispose();
            _channel?.Close();
        }
    }
}