< Summary

Information

Class:	Gateway.Apis.Amqp.RegistrationExtensions.ConsumerHost
Assembly:	Gateway
File(s):	/home/runner/work/dotnet-microservice/dotnet-microservice/Gateway/Apis/Amqp/RegistrationExtensions/ConsumerHost.cs
Tag:	34_11887803474

Line coverage

Branch coverage

Method coverage

Feature is only available for sponsors

Coverage history

Method	Branch coverage	Crap Score	Cyclomatic complexity	Line coverage
.ctor(...)	100%	2	1	0%
StartAsync(...)	100%	2	1	0%
StopAsync(...)	0%	20	4	0%

#	Line	Line coverage
	`1`	`using RabbitMQ.Client;`
	`2`
	`3`	`namespace Gateway.Apis.Amqp.RegistrationExtensions;`
	`4`
0	`5`	`public class ConsumerHost(IConnectionFactory connectionFactory, IServiceProvider serviceProvider)`
	`6`	`: IHostedService`
	`7`	`{`
0	`8`	`private readonly IConnectionFactory _connectionFactory = connectionFactory;`
0	`9`	`private readonly IServiceProvider _serviceProvider = serviceProvider;`
	`10`	`private IConnection? _connection;`
	`11`	`private IModel? _channel;`
	`12`
	`13`	`public Task StartAsync(CancellationToken cancellationToken)`
	`14`	`{`
0	`15`	`_connection = _connectionFactory.CreateConnection();`
0	`16`	`_channel = _connection.CreateModel();`
0	`17`	`AsyncApiConsumerFactoryBag.CreateConsumers(_channel, _serviceProvider);`
0	`18`	`return Task.CompletedTask;`
	`19`	`}`
	`20`
	`21`	`public Task StopAsync(CancellationToken cancellationToken)`
	`22`	`{`
0	`23`	`_connection?.Dispose();`
0	`24`	`_channel?.Dispose();`
0	`25`	`return Task.CompletedTask;`
	`26`	`}`
	`27`	`}`