Pregled: primenjeni kod
Klasa sadrži logiku za obradu novih porudžbina. Izvlači porudžbine i pozicije iz baze podataka, zatim pravi HTTP poziv ka eksternom mikroservisu Stock, u kojem rezerviše proizvode prema pozicijama porudžbine. Ako su sve rezervacije uspešno izvršene, mikroservis potvrđuje rezervaciju porudžbine u Stock i označava porudžbinu kao obrađenu. Mikroservis se pokreće u više instanci, pa metoda Process može biti izvršena paralelno. Da bi se izbegla obrada istih redova, koristi se mehanizam pesimističkog zaključavanja PostgreSQL Select for update ... skip locked. Implementacija IBus šalje poruke u 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;" }
};
```
