Έλεγχος: εφαρμοσμένος κώδικας
Η κλάση περιέχει τη λογική επεξεργασίας νέων παραγγελιών. Εξάγει τις παραγγελίες και τις θέσεις από τη βάση δεδομένων, στη συνέχεια πραγματοποιεί κλήση HTTP σε ένα εξωτερικό microservice Stock, στο οποίο κρατάει τα προϊόντα σύμφωνα με τις θέσεις της παραγγελίας. Αν όλες οι κρατήσεις ολοκληρωθούν με επιτυχία, το microservice επιβεβαιώνει την κράτηση της παραγγελίας στο Stock και σημειώνει την παραγγελία ως επεξεργασμένη. Το microservice τρέχει σε πολλαπλά αντίγραφα, επομένως η μέθοδος Process μπορεί να εκτελείται παράλληλα. Για να αποφευχθεί η επεξεργασία των ίδιων γραμμών, χρησιμοποιείται μηχανισμός απαισιόδοξης κλειδώματος PostgreSQL Select for update ... skip locked. Η υλοποίηση του IBus στέλνει μηνύματα στο 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;" }
};
```
