|
1 | 1 | using BeekmanLabs.UnitTesting; |
2 | 2 | using Common.Logging; |
3 | 3 | using IntegrationEngine.Api; |
4 | | -using IntegrationEngine.Core.Mail; |
5 | 4 | using IntegrationEngine.Core.MessageQueue; |
6 | 5 | using IntegrationEngine.Core.R; |
7 | 6 | using IntegrationEngine.Core.Storage; |
@@ -73,9 +72,9 @@ public void ShouldSetupMessageQueueListener() |
73 | 72 | { |
74 | 73 | Subject.LoadConfiguration(); |
75 | 74 |
|
76 | | - Subject.SetupAsyncListener(); |
| 75 | + Subject.SetupThreadedListenerManager(); |
77 | 76 |
|
78 | | - Subject.Container.Resolve<IMessageQueueListener>(); |
| 77 | + Subject.Container.Resolve<IThreadedListenerManager>(); |
79 | 78 | } |
80 | 79 |
|
81 | 80 | [Test] |
@@ -110,19 +109,14 @@ public void ShouldSetupRScriptRunner() |
110 | 109 | } |
111 | 110 |
|
112 | 111 | [Test] |
113 | | - public void ShouldShutdownSchedulerAndDisposeOfMessageQueueListener() |
| 112 | + public void ShouldDisposeOfResources() |
114 | 113 | { |
115 | | - var mockEngineScheduler = new Mock<IEngineScheduler>(); |
116 | | - mockEngineScheduler.Setup(x => x.Dispose()); |
117 | | - UnityContainer.RegisterInstance<IEngineScheduler>(mockEngineScheduler.Object); |
118 | | - var mockMessageQueueListener = new Mock<IMessageQueueListener>(); |
119 | | - mockMessageQueueListener.Setup(x => x.Dispose()); |
120 | | - UnityContainer.RegisterInstance<IMessageQueueListener>(mockMessageQueueListener.Object); |
121 | | - |
| 114 | + var mockWebApiApplication = new Mock<IWebApiApplication>(); |
| 115 | + Subject.WebApiApplication = mockWebApiApplication.Object; |
| 116 | + |
122 | 117 | Subject.Dispose(); |
123 | 118 |
|
124 | | - mockEngineScheduler.Verify(x => x.Dispose(), Times.Once); |
125 | | - mockMessageQueueListener.Verify(x => x.Dispose(), Times.Once); |
| 119 | + mockWebApiApplication.Verify(x => x.Dispose(), Times.Once); |
126 | 120 | } |
127 | 121 | } |
128 | 122 | } |
0 commit comments