rpc.post_execute

Dispatched once after successful method execution. $result is what the method returned, $params are the arguments after conversion.

Not dispatched on error (rpc.error is dispatched instead), for a cached response and for the receipt of notifications/callback.

Usage examples

Method execution time

final class TimingListener
{
    private array $started = [];

    #[AsEventListener(RpcEvent::PRE_EXECUTE, priority: 2000)]
    public function start(RpcPreExecuteEvent $event): void
    {
        $this->started[spl_object_id($event->rpcRequest)] = hrtime(true);
    }

    #[AsEventListener(RpcEvent::POST_EXECUTE)]
    public function finish(RpcPostExecuteEvent $event): void
    {
        $key = spl_object_id($event->rpcRequest);
        $ms = (hrtime(true) - ($this->started[$key] ?? hrtime(true))) / 1e6;
        unset($this->started[$key]);
        $this->metrics->histogram('rpc_duration_ms', $ms, ['method' => $event->service->name]);
    }
}

Domain events

After a successful Order.pay, publish an event to the application bus:

#[AsEventListener(RpcEvent::POST_EXECUTE)]
final class OrderPaidListener
{
    public function __construct(private MessageBusInterface $bus) {}

    public function __invoke(RpcPostExecuteEvent $event): void
    {
        if ($event->service->name === 'Order.pay' && $event->result === true) {
            $this->bus->dispatch(new OrderPaid($event->params['orderId']));
        }
    }
}