2
2
using Framework . MessageBroker . RabbitMQ . Explorer ;
3
3
using Framework . MessageBroker . Tests . RabbitMQ . Messages ;
4
4
using Framework . Test ;
5
+ using Microsoft . Extensions . DependencyInjection ;
5
6
using Shouldly ;
6
7
using System . Threading ;
7
8
using System . Threading . Tasks ;
@@ -16,15 +17,15 @@ public class Tests : BaseTest<Startup>
16
17
17
18
public Tests ( )
18
19
{
19
- _publisher = GetService < IRabbitMQPublisher > ( ) ;
20
- _rabbitExplorer = GetService < IRabbitMQExplorer > ( ) ;
20
+ _publisher = Scope . ServiceProvider . GetRequiredService < IRabbitMQPublisher > ( ) ;
21
+ _rabbitExplorer = Scope . ServiceProvider . GetRequiredService < IRabbitMQExplorer > ( ) ;
21
22
}
22
23
23
24
[ Fact ]
24
25
public async Task PublisheAndConsumeDefault ( )
25
26
{
26
27
//Arrange
27
- var subscriber = GetService < IRabbitMQSubscriber > ( ) ;
28
+ var subscriber = Scope . ServiceProvider . GetRequiredService < IRabbitMQSubscriber > ( ) ;
28
29
bool publishWithSuccess = false ;
29
30
var message = new DefaultMessage
30
31
{
@@ -58,7 +59,7 @@ public async Task PublisheAndConsumeDefault()
58
59
public async Task PublisheAndConsumeNamed ( )
59
60
{
60
61
//Arrange
61
- var subscriber = GetService < IRabbitMQSubscriber > ( ) ;
62
+ var subscriber = Scope . ServiceProvider . GetRequiredService < IRabbitMQSubscriber > ( ) ;
62
63
bool publishWithSuccess = false ;
63
64
var message = new NamedMessage
64
65
{
@@ -93,7 +94,7 @@ public async Task PublisheAndConsumeNamed()
93
94
public async Task PublisheAndConsumeDirectExchange ( )
94
95
{
95
96
//Arrange
96
- var subscriber = GetService < IRabbitMQSubscriber > ( ) ;
97
+ var subscriber = Scope . ServiceProvider . GetRequiredService < IRabbitMQSubscriber > ( ) ;
97
98
bool publishWithSuccess = false ;
98
99
var message = new DirectMessage
99
100
{
@@ -136,7 +137,7 @@ public async Task PublisheAndConsumeDirectExchange()
136
137
public async Task PublisheAndConsumeDefaultGeneratedName ( )
137
138
{
138
139
//Arrange
139
- var subscriber = GetService < IRabbitMQSubscriber > ( ) ;
140
+ var subscriber = Scope . ServiceProvider . GetRequiredService < IRabbitMQSubscriber > ( ) ;
140
141
bool publishWithSuccess = false ;
141
142
var message = new DefaultGeneratedNameMessage
142
143
{
@@ -171,7 +172,7 @@ public async Task PublisheAndConsumeDefaultGeneratedName()
171
172
public async Task PublisheAndConsumeDirectGeneratedName ( )
172
173
{
173
174
//Arrange
174
- var subscriber = GetService < IRabbitMQSubscriber > ( ) ;
175
+ var subscriber = Scope . ServiceProvider . GetRequiredService < IRabbitMQSubscriber > ( ) ;
175
176
bool publishWithSuccess = false ;
176
177
var message = new DirectedGeneratedNameMessage
177
178
{
@@ -214,7 +215,7 @@ public async Task PublisheAndConsumeDirectGeneratedName()
214
215
public async Task PublisheAndConsumeDefaultRejectedMessage ( )
215
216
{
216
217
//Arrange
217
- var subscriber = GetService < IRabbitMQSubscriber > ( ) ;
218
+ var subscriber = Scope . ServiceProvider . GetRequiredService < IRabbitMQSubscriber > ( ) ;
218
219
bool publishWithSuccess = false ;
219
220
int count = 0 ;
220
221
0 commit comments