testing-message-driven-architecture-in-php-01

testing-message-driven-architecture-in-php-01.php

<?php

class OrderService
{
    #[CommandHandler]
    public function place(PlaceOrder $placeOrder, OrderRepository $orderRepository, EventBus $eventBus): void
    {
        $orderRepository->save(Order::from($placeOrder));

        $eventBus->publish(new OrderWasPlaced($placeOrder->getOrderId()), []);
    }
}

class OrderNotifier
{
    #[Asynchronous('notifications')]
    #[EventHandler(endpointId: "order_notifier")]
    public function place(OrderWasPlaced $orderWasPlaced, NotificationService $notificationService): void
    {
        $notificationService->notifyAboutOrder($orderWasPlaced);
    }
}