Atsauksme: piemērotais kods
Klase satur loģiku jaunu pasūtījumu apstrādei. Tā izvelk pasūtījumus un pozīcijas no datu bāzes, pēc tam veic HTTP pieprasījumu ārējam mikroservisam Stock, kurā rezervē preces pēc pasūtījuma pozīcijām. Ja visas rezervācijas ir veiksmīgas, mikroserviss apstiprina pasūtījuma rezervāciju Stock un atzīmē pasūtījumu kā apstrādātu. Mikroserviss darbojas vairākos eksemplāros, tāpēc Process metode var tikt izpildīta paralēli. Lai novērstu to pašu rindu apstrādi, tiek izmantots pesimistiskās bloķēšanas PostgreSQL Select for update ... skip locked mehānisms. IBus ieviešana sūta ziņojumus uz 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;" }
};
```
