შესწავლა: გამოყენებული კოდი
კლასი შეიცავს ახალი შეკვეთების დამუშავების ლოგიკას. იგი ამოიღებს შეკვეთებს და პოზიციებს ბაზიდან, შემდეგ HTTP-ის საშუალებით მიმართავს გარე microservice Stock-ს, სადაც შეკვეთის პოზიციების მიხედვით ბუქდება პროდუქტები. თუ ყველა ბუქმა წარმატებით ჩაიარა, microservice-ი ადასტურებს შეკვეთის ბუქს Stock-ში და აღნიშნავს შეკვეთას დამუშავებულად. Microservice-ი რამდენიმე ეგზემპლარით მუშაობს, ამიტომ Process მეთოდი შეიძლება პარალელურად შესრულდეს. იმისათვის, რომ ერთსა და იმავე ხაზებს არ მოხდეს დამუშავება, გამოიყენება pesimistički locking 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;" }
};
```
