Add implementations

Author: ethanhann

IntegrationEngine/MessageQueue/IMessageQueueListener.cs

@@ -0,0 +1,13 @@
+using System;
+using System.Collections.Generic;
+using System.Linq;
+using System.Text;
+using System.Threading.Tasks;
+
+namespace IntegrationEngine.MessageQueue
+{
+    public interface IMessageQueueListener
+    {
+        void Listen();
+    }
+}

IntegrationEngine/MessageQueue/MsmqClient.cs

@@ -0,0 +1,53 @@
+using Common.Logging;
+using System;
+using System.Collections.Generic;
+using System.Linq;
+using System.Text;
+using System.Threading.Tasks;
+using MSMessageQueue = System.Messaging.MessageQueue;
+
+namespace IntegrationEngine.MessageQueue
+{
+    public class MsmqClient : IMessageQueueClient
+    {
+        public MSMessageQueue MSMessageQueue { get; set; }
+        string _queueName { get; set; }
+        public string QueueName { 
+            get { return _queueName; }
+            set {
+                if (!MSMessageQueue.Exists(QueueName))
+                    MSMessageQueue.Create(QueueName);
+                _queueName = value;
+            }
+        }
+        public ILog Log { get; set; }
+
+        public void Publish<T>(T value)
+        {
+            try
+            {
+                var message = value.GetType().FullName;
+                var body = Encoding.UTF8.GetBytes(message);
+                MSMessageQueue.Send(body);
+                Log.Debug(x => x("Sent message: {0}", message));
+            }
+            catch (Exception exception)
+            {
+                Log.Error(exception);
+            }
+        }
+
+        public bool IsServerAvailable()
+        {
+            try
+            {
+                return MSMessageQueue.Exists(QueueName);
+            }
+            catch (Exception exception)
+            {
+                Log.Error(exception);
+                return false;
+            }
+        }
+    }
+}

IntegrationEngine/MessageQueue/MsmqListener.cs

@@ -0,0 +1,70 @@
+using Common.Logging;
+using IntegrationEngine.Core.Jobs;
+using IntegrationEngine.Core.Mail;
+using IntegrationEngine.Core.Storage;
+using Nest;
+using System;
+using System.Collections.Generic;
+using System.Linq;
+using System.Messaging;
+using System.Text;
+using MSMessageQueue = System.Messaging.MessageQueue;
+
+namespace IntegrationEngine.MessageQueue
+{
+    public class MsmqListener : IMessageQueueListener
+    {
+        public IList<Type> IntegrationJobTypes { get; set; }
+        public ILog Log { get; set; }
+        public IMailClient MailClient { get; set; }
+        public IntegrationEngineContext IntegrationEngineContext { get; set; }
+        public IElasticClient ElasticClient { get; set; }
+        public MSMessageQueue MSMessageQueue { get; set; }
+        string _queueName { get; set; }
+        public string QueueName
+        {
+            get { return _queueName; }
+            set
+            {
+                if (!MSMessageQueue.Exists(QueueName))
+                    MSMessageQueue.Create(QueueName);
+                _queueName = value;
+            }
+        }
+
+        public void Listen()
+        {
+            Message newMessage = MSMessageQueue.Receive();
+            var body = newMessage.Body as byte[];
+            var message = Encoding.UTF8.GetString(body);
+            Log.Debug(x => x("Message queue listener received {0}", message));
+            if (IntegrationJobTypes != null && !IntegrationJobTypes.Any())
+                return;
+            var type = IntegrationJobTypes.FirstOrDefault(t => t.FullName.Equals(message));
+            var integrationJob = Activator.CreateInstance(type) as IIntegrationJob;
+            integrationJob = AutoWireJob(integrationJob, type);
+            try
+            {
+                if (integrationJob != null)
+                    integrationJob.Run();
+            }
+            catch (Exception exception)
+            {
+                Log.Error(x => x("Integration job did not run successfully ({0})}", message), exception);
+            }
+        }
+
+        T AutoWireJob<T>(T job, Type type)
+        {
+            if (type.GetInterface(typeof(IMailJob).Name) != null)
+                (job as IMailJob).MailClient = MailClient;
+            if (type.GetInterface(typeof(ISqlJob).Name) != null)
+                (job as ISqlJob).DbContext = IntegrationEngineContext;
+            if (type.GetInterface(typeof(ILogJob).Name) != null)
+                (job as ILogJob).Log = Log;
+            if (type.GetInterface(typeof(IElasticsearchJob).Name) != null)
+                (job as IElasticsearchJob).ElasticClient = ElasticClient;
+            return job;
+        }
+    }
+}