İnceleme: uygulanan kod
Sınıf, yeni siparişleri işleme mantığını içerir. Veritabanından siparişleri ve pozisyonları çıkarır, ardından harici bir mikroservis olan Stock'a HTTP çağrısı yapar ve sipariş pozisyonlarına göre ürünleri rezerve eder. Tüm rezervasyonlar başarılıysa, mikroservis sipariş rezervasyonunu onaylar ve siparişi işlenmiş olarak işaretler. Mikroservis birkaç örnekte çalıştırılır, bu nedenle Process yöntemi paralel olarak çalışabilir. Aynı satırların işlenmesini önlemek için PostgreSQL Select for update ... skip locked mekanizması kullanılır. IBus uygulaması, mesajları RabbitMq'ya gönderir.
```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;" }
};
```
