Күзәтү: кулланылган код
Класс яңа заказларны эшкәртү логикасын үз эченә ала. Ул базадан заказларны һәм позицияләрне чыгара, аннары тышкы микросервис Stockка HTTP соравы җибәрә, анда заказ позицияләренә карап товарлар броньләнә. Әгәр барлык броньләүләр уңышлы булса, микросервис заказ бронен Stockта раслый һәм заказны эшкәртелгән итеп билгели. Микросервис берничә экземплярда эшләтелә, шуңа күрә Process методы параллель рәвештә үтәлү мөмкин. Ун бер үк юлларны эшкәртүне булдырмас өчен, PostgreSQL Select for update ... skip locked механизмы кулланыла. IBus имплементациясе хәбәрләрне RabbitMqга җибәрә.
```csharp
public sealed class PendingOrdersProcessor
{
public async Task PendingOrdersProcessor(ILogger logger, IBus bus, HttpStockService st
{
var env = Environment.GetEnvironmentVariable("ASPNETCORE_ENVIRONMENT");
var cs = _cs[env];
_db = new OrdersRepository(cs);
_bus = bus;
logger = logger;
```
```csharp
_stockService = stockService;
}
private readonly ILogger _logger;
private readonly IOrdersRepository _db;
private readonly IStockService _stockService;
private readonly IBus _bus;
private static readonly Dictionary<string, string> _cs = new {
{ "Development",
"User ID=root;Password=myPassword;Host=localhost;Port=5432;Database=myDataBase"
},
{ "Production", "User ID=root;Password=myPassword;Host=prod-db;Port=5432;Database="
"Pooling=true;Min Pool Size=0;Max Pool Size=1;" }
};
```
