loosely-coupled-microservices-06.php

loosely-coupled-microservices-06.php

<?php

class OrderService
{
    #[EventHandler]
    public function placeOrder(OrderWasPlaced $event, DistributedBus $distributedBus, DomainService $domainService): void
    {
       $distributedBus->convertAndPublishEvent("order.was_placed",
          [
             "orderId" => $event->orderId()
          ],
          [
             "currentDomain" => $domainService->getDomain()
          ]
       );
    }
}

class AuditLogService
{
    #[Distributed]
    #[EventHandler("order.was_placed")]
    public function store(string $event, #[Header("currentDomain")] string $domain): void
    {
        // store order along with domain
    }
}