asynchronous-messaging-12.php

asynchronous-messaging-12.php

<?php

class PlaceOrdernHandler
{
    // default behaviour, first parameter is payload, second are headers
    #[CommandHandler("place_order")]
    public function placeOrder(PlaceOrder $payload, array $headers) {}
}


class PlaceOrdernHandler
{
    // taking over control with attributes
    #[CommandHandler("place_order")]
    public function placeOrder(
        #[Payload] PlaceOrder $payload, // injecting payload
        #[Header("executor_id")] string $executorId, // accessing direct Message Header
        #[Reference] AuthorizationService $service // injecting service from DI Container
    ) {}
}