<?php

use Enqueue\Consumption\Result;
use Enqueue\Psr\PsrContext;
use Enqueue\Psr\PsrMessage;
use Enqueue\Psr\PsrProcessor;

class RpcProcessor implements PsrProcessor
{
    public function process(PsrMessage $message, PsrContext $context)
    {
        // do the job

        //send reply
        return Result::reply($context->createMessage('reply_data'));
    }
}