Register remaining integration points

ethanhann · ethanhann · commit cf74b6970c3b · 2015-02-16T20:07:45.000-05:00
diff --git a/IntegrationEngine.ConsoleHost/IntegrationJobs/CarReport/CarMailMessageJob.cs b/IntegrationEngine.ConsoleHost/IntegrationJobs/CarReport/CarMailMessageJob.cs
@@ -11,7 +11,6 @@ namespace IntegrationEngine.ConsoleHost.Car
     public class CarMailMessageJob : IMailJob, IParameterizedJob
     {
         public IMailClient MailClient { get; set; }
-        public IMailClient SecondMailClient { get; set; }
         public IDictionary<string, string> Parameters { get; set; }
 
         public CarMailMessageJob()
@@ -26,15 +25,12 @@ public CarMailMessageJob(FooMailClient mailClient)
 
         public void Run()
         {
-            var areEqual = MailClient == SecondMailClient;
-            Console.WriteLine(areEqual);
-            SecondMailClient = MailClient;
-            //var mailMessage = new MailMessage();
-            //mailMessage.To.Add("ethanhann@gmail.com");
-            //mailMessage.Subject = "Your car report is ready.";
-            //mailMessage.From = new MailAddress("root@localhost");
-            //mailMessage.Body = "Body content about cars.";
-            //MailClient.Send(mailMessage);
+            var mailMessage = new MailMessage();
+            mailMessage.To.Add("ethanhann@gmail.com");
+            mailMessage.Subject = "Your car report is ready.";
+            mailMessage.From = new MailAddress("root@localhost");
+            mailMessage.Body = "Body content about cars.";
+            MailClient.Send(mailMessage);
         }
     }
 }
diff --git a/IntegrationEngine.Core/Configuration/ElasticsearchConfiguration.cs b/IntegrationEngine.Core/Configuration/ElasticsearchConfiguration.cs
@@ -1,4 +1,5 @@
-﻿
+﻿using System.Linq;
+
 namespace IntegrationEngine.Core.Configuration
 {
     public class ElasticsearchConfiguration : IElasticsearchConfiguration
@@ -8,5 +9,20 @@ public class ElasticsearchConfiguration : IElasticsearchConfiguration
         public string HostName { get; set; }
         public int Port { get; set; }
         public string DefaultIndex { get; set; }
+
+        public ElasticsearchConfiguration()
+        {
+        }
+
+        public ElasticsearchConfiguration(IEngineConfiguration engineConfiguration, string integrationPointName)
+            : this()
+        {
+            var config = engineConfiguration.IntegrationPoints.Elasticsearch.Single(x => x.IntegrationPointName == integrationPointName);
+            IntegrationPointName = integrationPointName;
+            Protocol = config.Protocol;
+            HostName = config.HostName;
+            Port = config.Port;
+            DefaultIndex = config.DefaultIndex;
+        }
     }
 }
diff --git a/IntegrationEngine.Core/Configuration/MailConfiguration.cs b/IntegrationEngine.Core/Configuration/MailConfiguration.cs
@@ -16,6 +16,7 @@ public MailConfiguration(IEngineConfiguration engineConfiguration, string integr
             : this()
         {
             var config = engineConfiguration.IntegrationPoints.Mail.Single(x => x.IntegrationPointName == integrationPointName);
+            IntegrationPointName = integrationPointName;
             HostName = config.HostName;
             Port = config.Port;
         }
diff --git a/IntegrationEngine.Core/Configuration/RabbitMQConfiguration.cs b/IntegrationEngine.Core/Configuration/RabbitMQConfiguration.cs
@@ -1,4 +1,5 @@
-﻿
+﻿using System.Linq;
+
 namespace IntegrationEngine.Core.Configuration
 {
     public class RabbitMQConfiguration : IRabbitMQConfiguration
@@ -10,5 +11,22 @@ public class RabbitMQConfiguration : IRabbitMQConfiguration
         public string Password { get; set; }
         public string HostName { get; set; }
         public string VirtualHost { get; set; }
+
+        public RabbitMQConfiguration()
+        {
+        }
+
+        public RabbitMQConfiguration(IEngineConfiguration engineConfiguration, string integrationPointName)
+            : this()
+        {
+            var config = engineConfiguration.IntegrationPoints.RabbitMQ.Single(x => x.IntegrationPointName == integrationPointName);
+            IntegrationPointName = integrationPointName;
+            QueueName = config.QueueName;
+            ExchangeName = config.ExchangeName;
+            UserName = config.UserName;
+            Password = config.Password;
+            HostName = config.HostName;
+            VirtualHost = config.VirtualHost;
+        }
     }
 }
diff --git a/IntegrationEngine.Core/IntegrationEngine.Core.csproj b/IntegrationEngine.Core/IntegrationEngine.Core.csproj
@@ -127,6 +127,8 @@
     <Compile Include="Configuration\IntegrationPointConfigurations.cs" />
     <Compile Include="R\IRScriptRunner.cs" />
     <Compile Include="MessageQueue\MessageQueueConnection.cs" />
+    <Compile Include="MessageQueue\IRabbitMQClient.cs" />
+    <Compile Include="MessageQueue\IMsmqClient.cs" />
   </ItemGroup>
   <ItemGroup>
     <None Include="App.config" />
diff --git a/IntegrationEngine.Core/MessageQueue/IMsmqClient.cs b/IntegrationEngine.Core/MessageQueue/IMsmqClient.cs
@@ -0,0 +1,8 @@
+﻿using System;
+using System.Collections.Generic;
+
+namespace IntegrationEngine.Core.MessageQueue
+{
+    public interface IMsmqClient : IMessageQueueClient
+    {}
+}
diff --git a/IntegrationEngine.Core/MessageQueue/IRabbitMQClient.cs b/IntegrationEngine.Core/MessageQueue/IRabbitMQClient.cs
@@ -0,0 +1,8 @@
+﻿using System;
+using System.Collections.Generic;
+
+namespace IntegrationEngine.Core.MessageQueue
+{
+    public interface IRabbitMQClient : IMessageQueueClient
+    {}
+}
diff --git a/IntegrationEngine.Core/MessageQueue/MsmqClient.cs b/IntegrationEngine.Core/MessageQueue/MsmqClient.cs
@@ -1,12 +1,12 @@
-﻿﻿using Common.Logging;
+﻿using Common.Logging;
 using System;
 using System.Collections.Generic;
 using System.Text;
 using MSMessageQueue = System.Messaging.MessageQueue;
 
 namespace IntegrationEngine.Core.MessageQueue
 {
-    public class MsmqClient : IMessageQueueClient
+    public class MsmqClient : IMsmqClient
     {
         public MSMessageQueue MSMessageQueue { get; set; }
         string _queueName { get; set; }
diff --git a/IntegrationEngine.Core/MessageQueue/RabbitMQClient.cs b/IntegrationEngine.Core/MessageQueue/RabbitMQClient.cs
@@ -10,7 +10,7 @@
 
 namespace IntegrationEngine.Core.MessageQueue
 {
-    public class RabbitMQClient : IMessageQueueClient
+    public class RabbitMQClient : IRabbitMQClient
     {
         public RabbitMQConfiguration MessageQueueConfiguration { get; set; }
         public IMessageQueueConnection MessageQueueConnection { get; set; }
diff --git a/IntegrationEngine.Tests/EngineHostCompositionRootTest.cs b/IntegrationEngine.Tests/EngineHostCompositionRootTest.cs
@@ -4,7 +4,7 @@
 using IntegrationEngine.Api;
 using IntegrationEngine.Core.Configuration;
 using IntegrationEngine.Core.R;
-using IntegrationEngine.MessageQueue;
+using IntegrationEngine.JobProcessor;
 using Microsoft.Practices.Unity;
 using Moq;
 using Nest;
@@ -47,8 +47,9 @@ public void ShouldSetupLogging()
         public void ShouldSetupMessageQueueListener()
         {
             Subject.LoadConfiguration();
-            Subject.Container.RegisterType<IRabbitMQConfiguration, RabbitMQConfiguration>("DefaultRabbitMQ");
-
+            var configName = "DefaultRabbitMQ";
+            Subject.Container.RegisterType<IRabbitMQConfiguration, RabbitMQConfiguration>(configName,
+                new InjectionConstructor(new ResolvedParameter<IEngineConfiguration>(), configName));
 
             Subject.SetupThreadedListenerManager();
 
diff --git a/IntegrationEngine.userprefs b/IntegrationEngine.userprefs
@@ -1,18 +1,23 @@
 ﻿<Properties StartupItem="IntegrationEngine.ConsoleHost/IntegrationEngine.ConsoleHost.csproj">
   <MonoDevelop.Ide.Workspace ActiveConfiguration="Debug" />
-  <MonoDevelop.Ide.Workbench ActiveDocument="IntegrationEngine.ConsoleHost/IntegrationJobs/CarReport/CarMailMessageJob.cs">
+  <MonoDevelop.Ide.Workbench ActiveDocument="IntegrationEngine/EngineHostCompositionRoot.cs">
     <Files>
-      <File FileName="IntegrationEngine/EngineHostCompositionRoot.cs" Line="27" Column="27" />
-      <File FileName="IntegrationEngine.ConsoleHost/IntegrationJobs/CarReport/CarMailMessageJob.cs" Line="6" Column="6" />
-      <File FileName="IntegrationEngine.Core/Configuration/IMailConfiguration.cs" Line="1" Column="1" />
-      <File FileName="IntegrationEngine/EngineConfiguration.cs" Line="3" Column="3" />
-      <File FileName="IntegrationEngine.Core/Configuration/IntegrationPointConfigurations.cs" Line="31" Column="31" />
-      <File FileName="configuration/IntegrationEngine.json" Line="10" Column="10" />
-      <File FileName="IntegrationEngine.Core/Configuration/MailConfiguration.cs" Line="13" Column="13" />
+      <File FileName="IntegrationEngine/EngineHostCompositionRoot.cs" Line="85" Column="85" />
+      <File FileName="IntegrationEngine.Tests/EngineHostCompositionRootTest.cs" Line="1" Column="1" />
     </Files>
     <Pads>
       <Pad Id="MonoDevelop.NUnit.TestPad">
-        <State expanded="True" selected="True" />
+        <State expanded="True">
+          <Node name="IntegrationEngine.Tests" expanded="True">
+            <Node name="IntegrationEngine" expanded="True">
+              <Node name="Tests" expanded="True">
+                <Node name="EngineHostCompositionRootTest" expanded="True">
+                  <Node name="ShouldSetupMessageQueueListener" selected="True" />
+                </Node>
+              </Node>
+            </Node>
+          </Node>
+        </State>
       </Pad>
     </Pads>
   </MonoDevelop.Ide.Workbench>
diff --git a/IntegrationEngine/Api/Controllers/HealthStatusController.cs b/IntegrationEngine/Api/Controllers/HealthStatusController.cs
@@ -1,7 +1,7 @@
 ﻿using IntegrationEngine.Scheduler;
 using IntegrationEngine.Core.Mail;
 using IntegrationEngine.Core.Storage;
-using IntegrationEngine.MessageQueue;
+using IntegrationEngine.JobProcessor;
 using InEngineHealthStatus = IntegrationEngine.Model.HealthStatus;
 using Nest;
 using System;
diff --git a/IntegrationEngine/EngineHostCompositionRoot.cs b/IntegrationEngine/EngineHostCompositionRoot.cs
@@ -8,7 +8,7 @@
 using IntegrationEngine.Core.MessageQueue;
 using IntegrationEngine.Core.R;
 using IntegrationEngine.Core.Storage;
-using IntegrationEngine.MessageQueue;
+using IntegrationEngine.JobProcessor;
 using IntegrationEngine.Scheduler;
 using Microsoft.Practices.Unity;
 using Nest;
@@ -87,50 +87,51 @@ public void RegisterIntegrationPoints()
             Container.RegisterType<INestSerializer, NestSerializer>();
             Container.RegisterType<Elasticsearch.Net.Connection.ITransport, Elasticsearch.Net.Connection.Transport>();
             Container.RegisterType<IConnectionSettingsValues, ConnectionSettings>();
-            //Container.RegisterType<IMailConfiguration, MailConfiguration>();
             foreach (var config in EngineConfiguration.IntegrationPoints.Mail) {
-//                Container.RegisterInstance<IMailConfiguration>(config.IntegrationPointName, config);
                 Container.RegisterType<IMailConfiguration, MailConfiguration>(config.IntegrationPointName,
                     new InjectionConstructor(
                         new ResolvedParameter<IEngineConfiguration>(),
                         config.IntegrationPointName
                     )
                 );
-
-                //Container.RegisterType<Func<string, IMailConfiguration>>(
-                //    new InjectionFactory(c => new Func<string, IMailConfiguration>(name => c.Resolve<IMailConfiguration>(name))));
-
                 Container.RegisterType<IMailClient, MailClient>(config.IntegrationPointName, new InjectionConstructor(config));
             }
-            
-            
-
 
-            foreach (var config in EngineConfiguration.IntegrationPoints.Elasticsearch) {
-                Container.RegisterInstance<IElasticsearchConfiguration>(config.IntegrationPointName, config);
+            Func<IUnityContainer, Type, string, object> elasticClientFactory = (container, type, configName) => {
+                var config = container.Resolve<IElasticsearchConfiguration>(configName);
                 var serverUri = new UriBuilder(config.Protocol, config.HostName, config.Port).Uri;
                 var settings = new ConnectionSettings(serverUri, config.DefaultIndex);
-                var client = new ElasticClient(settings);
-                Container.RegisterInstance<IElasticClient>(config.IntegrationPointName, client);
-//                Container.RegisterType<IElasticClient, ElasticClient>(config.IntegrationPointName,
-//                    new InjectionConstructor(
-//                        settings,
-//                        new ResolvedParameter<Elasticsearch.Net.Connection.IConnection>(),
-//                        new ResolvedParameter<INestSerializer>(),
-//                        new ResolvedParameter<Elasticsearch.Net.Connection.ITransport>())
-//                );
+                return new ElasticClient(settings);
+            };
+            foreach (var config in EngineConfiguration.IntegrationPoints.Elasticsearch) {
+                Container.RegisterType<IElasticsearchConfiguration, ElasticsearchConfiguration>(config.IntegrationPointName,
+                    new InjectionConstructor(
+                        new ResolvedParameter<IEngineConfiguration>(),
+                        config.IntegrationPointName
+                    )
+                );
+                Container.RegisterType<IElasticClient, ElasticClient>(config.IntegrationPointName, 
+                    new InjectionFactory(elasticClientFactory));
             }
             foreach (var config in EngineConfiguration.IntegrationPoints.RabbitMQ) {
-                Container.RegisterInstance<IRabbitMQConfiguration>(config.IntegrationPointName, config);
-                Container.RegisterType<IMessageQueueClient, RabbitMQClient>(config.IntegrationPointName, new InjectionConstructor(config));
+                Container.RegisterType<IRabbitMQConfiguration, RabbitMQConfiguration>(config.IntegrationPointName,
+                    new InjectionConstructor(
+                        new ResolvedParameter<IEngineConfiguration>(),
+                        config.IntegrationPointName
+                    )
+                );
+                Container.RegisterType<IRabbitMQClient, RabbitMQClient>(config.IntegrationPointName, new InjectionConstructor(config));
             }
         }
 
+        /// <summary>
+        /// Registers the integration jobs.
+        /// Resolve the integration point type (specified in a job's parameters).
+        /// Configure the integration point type with a configuration, based on a parameter's name.                    
+        /// </summary>
         public void RegisterIntegrationJobs()
         {
             IntegrationJobTypes.ForEach(jobType => {
-                // Resolve the integration point type (specified in the job's parameters).
-                // Configure the integration point type with a configuration, based on the parameter name.                    
                 Func<ParameterInfo[], object[]> resolveParameters = infos => {
                     var resolvedParameters = new List<object>();
                     foreach (var parameterInfo in infos)
@@ -139,6 +140,10 @@ public void RegisterIntegrationJobs()
                         var parameterName = parameterInfo.ParameterType.Name; // The name of the configuration endpoint (e.g. "MyElasticClient")
                         if (typeof(IMailClient).IsAssignableFrom(parameterType))
                             resolvedParameters.Add(Activator.CreateInstance(parameterType, Container.Resolve<IMailConfiguration>(parameterName)));
+                        if (typeof(IRabbitMQClient).IsAssignableFrom(parameterType))
+                            resolvedParameters.Add(Activator.CreateInstance(parameterType, Container.Resolve<IRabbitMQConfiguration>(parameterName)));
+                        if (typeof(IElasticClient).IsAssignableFrom(parameterType))
+                            resolvedParameters.Add(Activator.CreateInstance(parameterType, Container.Resolve<IElasticsearchConfiguration>(parameterName)));
                     }
                     return resolvedParameters.Cast<object>().ToArray();
                 };
@@ -173,7 +178,7 @@ public void SetupThreadedListenerManager()
         public void SetupEngineScheduler()
         {
             var dispatcher = new Dispatcher() {
-                MessageQueueClient = Container.Resolve<IMessageQueueClient>("DefaultRabbitMQ"),
+                MessageQueueClient = Container.Resolve<IRabbitMQClient>("DefaultRabbitMQ"),
             };
             var engineScheduler = new EngineScheduler() {
                 Scheduler = StdSchedulerFactory.GetDefaultScheduler(),
diff --git a/IntegrationEngine/IntegrationEngine.csproj b/IntegrationEngine/IntegrationEngine.csproj
@@ -149,12 +149,7 @@
     <Compile Include="Api\WebApiApplication.cs" />
     <Compile Include="Api\WebApiStartup.cs" />
     <Compile Include="DataAnnotations\CronExpressionStringAttribute.cs" />
-    <Compile Include="MessageQueue\IThreadedListenerManager.cs" />
-    <Compile Include="MessageQueue\ThreadedListenerManager.cs" />
     <Compile Include="Scheduler\Dispatcher.cs" />
-    <Compile Include="MessageQueue\IMessageQueueListener.cs" />
-    <Compile Include="MessageQueue\MsmqListener.cs" />
-    <Compile Include="MessageQueue\RabbitMQListener.cs" />
     <Compile Include="Scheduler\CronTrigger.cs" />
     <Compile Include="Scheduler\IDispatcher.cs" />
     <Compile Include="Scheduler\IEngineSchedulerListener.cs" />
@@ -174,8 +169,13 @@
     <Compile Include="Api\Controllers\HealthStatusController.cs" />
     <Compile Include="Api\TriggerControllerBase.cs" />
     <Compile Include="Api\Controllers\LogEventController.cs" />
-    <Compile Include="EngineConfiguration.cs" />
     <Compile Include="EngineHostCompositionRoot.cs" />
+    <Compile Include="JobProcessor\IThreadedListenerManager.cs" />
+    <Compile Include="JobProcessor\ThreadedListenerManager.cs" />
+    <Compile Include="JobProcessor\IMessageQueueListener.cs" />
+    <Compile Include="JobProcessor\MsmqListener.cs" />
+    <Compile Include="JobProcessor\RabbitMQListener.cs" />
+    <Compile Include="EngineConfiguration.cs" />
   </ItemGroup>
   <Import Project="$(MSBuildBinPath)\Microsoft.CSharp.targets" />
   <ItemGroup>
diff --git a/IntegrationEngine/JobProcessor/IMessageQueueListener.cs b/IntegrationEngine/JobProcessor/IMessageQueueListener.cs
@@ -1,7 +1,7 @@
 ﻿using System;
 using System.Threading;
 
-namespace IntegrationEngine.MessageQueue
+namespace IntegrationEngine.JobProcessor
 {
     public interface IMessageQueueListener : IDisposable
     {
diff --git a/IntegrationEngine/JobProcessor/IThreadedListenerManager.cs b/IntegrationEngine/JobProcessor/IThreadedListenerManager.cs
@@ -15,7 +15,7 @@
 using System.Text;
 using System.Threading;
 
-namespace IntegrationEngine.MessageQueue
+namespace IntegrationEngine.JobProcessor
 {
     public interface IThreadedListenerManager : IDisposable
     {
diff --git a/IntegrationEngine/JobProcessor/MsmqListener.cs b/IntegrationEngine/JobProcessor/MsmqListener.cs
@@ -11,7 +11,7 @@
 using System.Threading;
 using MSMessageQueue = System.Messaging.MessageQueue;
 
-namespace IntegrationEngine.MessageQueue
+namespace IntegrationEngine.JobProcessor
 {
     public class MsmqListener : IMessageQueueListener
     {
diff --git a/IntegrationEngine/JobProcessor/RabbitMQListener.cs b/IntegrationEngine/JobProcessor/RabbitMQListener.cs
@@ -19,7 +19,7 @@
 using System.Threading;
 using Microsoft.Practices.Unity;
 
-namespace IntegrationEngine.MessageQueue
+namespace IntegrationEngine.JobProcessor
 {
     public class RabbitMQListener : IMessageQueueListener
     {
diff --git a/IntegrationEngine/JobProcessor/ThreadedListenerManager.cs b/IntegrationEngine/JobProcessor/ThreadedListenerManager.cs
@@ -15,7 +15,7 @@
 using System.Text;
 using System.Threading;
 
-namespace IntegrationEngine.MessageQueue
+namespace IntegrationEngine.JobProcessor
 {
     public class ThreadedListenerManager : IThreadedListenerManager
     {
diff --git a/IntegrationEngine/Scheduler/EngineScheduler.cs b/IntegrationEngine/Scheduler/EngineScheduler.cs
@@ -1,7 +1,7 @@
 ﻿using Common.Logging;
 using IntegrationEngine.Core.Jobs;
 using IntegrationEngine.Core.MessageQueue;
-using IntegrationEngine.MessageQueue;
+using IntegrationEngine.JobProcessor;
 using IntegrationEngine.Model;
 using Quartz;
 using System;

Original file line number	Diff line number	Diff line change
`@@ -11,7 +11,6 @@ namespace IntegrationEngine.ConsoleHost.Car`
`11`	`11`	`public class CarMailMessageJob : IMailJob, IParameterizedJob`
`12`	`12`	`{`
`13`	`13`	`public IMailClient MailClient { get; set; }`
`14`		`- public IMailClient SecondMailClient { get; set; }`
`15`	`14`	`public IDictionary<string, string> Parameters { get; set; }`
`16`	`15`
`17`	`16`	`public CarMailMessageJob()`
`@@ -26,15 +25,12 @@ public CarMailMessageJob(FooMailClient mailClient)`
`26`	`25`
`27`	`26`	`public void Run()`
`28`	`27`	`{`
`29`		`- var areEqual = MailClient == SecondMailClient;`
`30`		`- Console.WriteLine(areEqual);`
`31`		`- SecondMailClient = MailClient;`
`32`		`- //var mailMessage = new MailMessage();`
`33`		`- //mailMessage.To.Add("ethanhann@gmail.com");`
`34`		`- //mailMessage.Subject = "Your car report is ready.";`
`35`		`- //mailMessage.From = new MailAddress("root@localhost");`
`36`		`- //mailMessage.Body = "Body content about cars.";`
`37`		`- //MailClient.Send(mailMessage);`
	`28`	`+ var mailMessage = new MailMessage();`
	`29`	`+ mailMessage.To.Add("ethanhann@gmail.com");`
	`30`	`+ mailMessage.Subject = "Your car report is ready.";`
	`31`	`+ mailMessage.From = new MailAddress("root@localhost");`
	`32`	`+ mailMessage.Body = "Body content about cars.";`
	`33`	`+ MailClient.Send(mailMessage);`
`38`	`34`	`}`
`39`	`35`	`}`
`40`	`36`	`}`
Original file line number	Diff line number	Diff line change
`@@ -16,6 +16,7 @@ public MailConfiguration(IEngineConfiguration engineConfiguration, string integr`
`16`	`16`	`: this()`
`17`	`17`	`{`
`18`	`18`	`var config = engineConfiguration.IntegrationPoints.Mail.Single(x => x.IntegrationPointName == integrationPointName);`
	`19`	`+ IntegrationPointName = integrationPointName;`
`19`	`20`	`HostName = config.HostName;`
`20`	`21`	`Port = config.Port;`
`21`	`22`	`}`
Original file line number	Diff line number	Diff line change
`@@ -1,12 +1,12 @@`
`1`		`-using Common.Logging;`
	`1`	`+using Common.Logging;`
`2`	`2`	`using System;`
`3`	`3`	`using System.Collections.Generic;`
`4`	`4`	`using System.Text;`
`5`	`5`	`using MSMessageQueue = System.Messaging.MessageQueue;`
`6`	`6`
`7`	`7`	`namespace IntegrationEngine.Core.MessageQueue`
`8`	`8`	`{`
`9`		`- public class MsmqClient : IMessageQueueClient`
	`9`	`+ public class MsmqClient : IMsmqClient`
`10`	`10`	`{`
`11`	`11`	`public MSMessageQueue MSMessageQueue { get; set; }`
`12`	`12`	`string _queueName { get; set; }`
Original file line number	Diff line number	Diff line change
`@@ -10,7 +10,7 @@`
`10`	`10`
`11`	`11`	`namespace IntegrationEngine.Core.MessageQueue`
`12`	`12`	`{`
`13`		`- public class RabbitMQClient : IMessageQueueClient`
	`13`	`+ public class RabbitMQClient : IRabbitMQClient`
`14`	`14`	`{`
`15`	`15`	`public RabbitMQConfiguration MessageQueueConfiguration { get; set; }`
`16`	`16`	`public IMessageQueueConnection MessageQueueConnection { get; set; }`