mikhail/parr_api
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Merge branch 'update-rqbbitmq' into dev

Browse Source
This commit is contained in:
Mikhail Trubnikov
2025-08-20 14:12:25 +10:00
parent a81f188cb7 85798c0956
commit 01bd5b7b27
58 changed files with 621 additions and 341 deletions
Download Patch File Download Diff File Expand all files Collapse all files

7
PARR.TemplateGeneratorWorker/Worker.cs
View File

@@ -35,19 +35,16 @@ namespace PARR.TemplateGeneratorWorker
protected override async Task ExecuteAsync(CancellationToken stoppingToken)
{
while (!stoppingToken.IsCancellationRequested)
{
var isConnected = mqService.InitConsumer(mqSettings, GenerateTemplateAsync);
var isConnected = await mqService.InitConsumerAsync(mqSettings, GenerateTemplateAsync);
if (!isConnected)
throw new Exception("<22><><EFBFBD><EFBFBD><EFBFBD><EFBFBD> <20><><EFBFBD> <20><><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD> <20> RabbitMq");
}
}
public override Task StopAsync(CancellationToken cancellationToken)
{
mqService.Dispose();
mqService.DisposeAsync().AsTask().Wait();
return base.StopAsync(cancellationToken);
}