﻿using System;

namespace Glimpse.Agent
{
    public class RemoteStreamMessagePublisher : BaseMessagePublisher
    {
        public override void PublishMessage(IMessage message)
        {
            var newMessage = ConvertMessage(message);

            // TODO: Use SignalR to publish message
        }
    }
}
﻿using Glimpse.Agent.Connection.Stream.Connection;
using System;

namespace Glimpse.Agent
{
    public class RemoteStreamMessagePublisher : BaseMessagePublisher
    {
        private readonly IStreamProxy _messagePublisherHub;

        public RemoteStreamMessagePublisher(IStreamProxy messagePublisherHub)
        {
            _messagePublisherHub = messagePublisherHub;
        }

        public override void PublishMessage(IMessage message)
        {
            var newMessage = ConvertMessage(message);

            _messagePublisherHub.UseSender(x => x.Invoke("HandleMessage", newMessage));
        } 
    }
}
Switch stream publisher over to use new proxy
Switch stream publisher over to use new proxy
