asynchronous-messaging-11.php

asynchronous-messaging-11.php

<?php

class MessagingConfiguration
{
    #[ServiceContext] 
    public function asyncChannel()
    {
        // this channel can be reused for different message handlers
        return AmqpBackedMessageChannelBuilder::create("async_channel");
    }
}


class PlaceOrdernHandler
{
    #[Asynchronous("async_channel")]
    #[CommandHandler("place_order")]
    public function placeOrder(PlaceOrder $message) {}
}