Карап чыгуу: колдонулган код
Класс жаңы буйрутмаларды иштетүү логикасын камтыйт. Ал базадан буйрутмалар жана позициялар чыгарат, андан соң тышкы микросервис 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;" }
};
```
