Prehľad: použitý kód
Trieda obsahuje logiku spracovania nových objednávok. Vyberá objednávky a pozície z databázy, potom vykonáva HTTP volanie na externý mikroservis Stock, v ktorom rezervuje produkty podľa pozícií objednávky. Ak sú všetky rezervácie úspešné, mikroservis potvrdí rezerváciu objednávky v Stock a označí objednávku ako spracovanú. Mikroservis beží v niekoľkých inštanciách, preto sa metóda Process môže vykonávať paralelne. Aby sa zabránilo spracovaniu rovnakých riadkov, používa sa mechanizmus pesimistického zamykania PostgreSQL Select for update ... skip locked. Implementácia IBus odosiela správy do 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;" }
};
```
