Review: toegepaste code
De klasse bevat de logica voor het verwerken van nieuwe bestellingen. Haalt de bestellingen en posities uit de database, doet vervolgens een HTTP-aanroep naar een externe microservice Stock, waarin de producten worden gereserveerd volgens de posities van de bestelling. Als alle reserveringen succesvol zijn, bevestigt de microservice de reservering van de bestelling in Stock en markeert de bestelling als verwerkt. De microservice wordt in meerdere exemplaren uitgevoerd, dus de methode Process kan parallel worden uitgevoerd. Om te voorkomen dat dezelfde regels worden verwerkt, wordt een mechanisme van pessimistische vergrendeling in PostgreSQL Select for update ... skip locked gebruikt. De implementatie van IBus stuurt berichten naar 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;" }
};
```
