asynchronous-messaging-13.php

asynchronous-messaging-13.php

<?php
// Configuration on Publisher Side

public function changeBillingDetails(DistributedBus $distributedCommandBus)
{
    $distributedCommandBus->sendCommand(
        "billing", // destination
        "billing.changeDetails", // routingKey
        '["personId":"123","billingDetails":"01111"]',
        "application/json"
    );
    
    // or, if you want delegate serialization to Ecotone or you woud like to share classes between applications
    $distributedCommandBus->convertAndSendCommand(
        "billing", // destination
        "billing.changeDetails", // routingKey
        new ChangeBillingDetails(// data),
        "application/json"
    );
}

// Configuration on "billing" Service - Consumer Side

#[Distributed]
#[CommandHandler("billing.changeDetails")]
public function changeBillingDetails(ChangeBillingDetails $command) : void
{
    // Ecotone will deserialize the payload to ChangeBillingDetails automatically.
    // There is no need to share classes between Applications.
}