Streaming live results to a web site using MSMQ/Duplex WCF/SignalR/jQuery

using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using Codeproject.EventBroker.Service.Services.Contracts;
using Codeproject.EventBroker.Contracts.Data;
using System.Net;
using Codeproject.EventBroker.Common;
using System.Xml.Linq;

namespace Codeproject.EventBroker.Service.Utils.Implementation
{
    public class XmlParser : IXmlParser
    {

        private IGeoLocator geoLocator;

        public XmlParser(IGeoLocator geoLocator)
        {
            this.geoLocator = geoLocator;
        }

        public RealTimeEventMessage ParseRawMsmqXml(string messageBody)
        {
            //<realtimeEvent>
            //  <originatingIp></originatingIp>
            //  <eventName>ClientDealEvent</eventName>
            //  <entityIdType>ClientDeal</entityIdType>
            //  <description>Someone bought something</description>
            //  <date>2012-01-16T15:31:31</date>
            //  <additionalData></additionalData>
            //</realtimeEvent>

            try
            {
                RealTimeEventMessage info = new RealTimeEventMessage();
                XElement xelement = XElement.Parse(messageBody);
                string ipAddress = GetSafeString(xelement, "originatingIp"); 
                if (!string.IsNullOrEmpty(ipAddress))
                {
                    info.Location = geoLocator.ObtainLocationForIPAddress(ipAddress);
                }
                info.EventName = GetSafeString(xelement, "eventName");
                info.EntityIdType = GetSafeString(xelement, "entityIdType");
                info.Description = GetSafeString(xelement, "description").Replace("\n\n", "\n\r");
                info.Date = GetSafeDate(xelement, "date");
                info.AdditionalData = GetSafeString(xelement, "additionalData");
                return info;

            }
            catch (Exception ex)
            {
                LogManager.Log.Error(ex);
                return null;
            }
        }


        public static Int32 GetSafeInt32(XElement root, string elementName)
        {
            try
            {
                XElement element = root.Elements().Where(node => node.Name.LocalName == elementName).Single();
                return Convert.ToInt32(element.Value);
            }
            catch
            {
                return 0;
            }
        }


        private static DateTime? GetSafeDate(XElement root, string elementName)
        {
            try
            {
                XElement element = root.Elements().Where(node => node.Name.LocalName == elementName).Single();
                return DateTime.Parse(element.Value);
            }
            catch
            {
                return null;
            }
        }



        public static String GetSafeString(XElement root, string elementName)
        {
            try
            {
                XElement element = root.Elements().Where(node => node.Name.LocalName == elementName).Single();
                return element.Value;
            }
            catch
            {
                return String.Empty;
            }
        }       




    }
}