[OK] Consuming messages from transports "async".


 // The worker will automatically exit once it has received a stop signal via the messenger:stop-workers command.

 // Quit the worker with CONTROL-C.

 // Re-run the command with a -vv option to see logs about consumed messages.

{"message":"Received message AppBundle\\Message\\CurlRequest","context":{"message":{},"class":"AppBundle\\Message\\CurlRequest"},"level":200,"level_name":"INFO","channel":"messenger","datetime":"2022-01-31T18:54:15.008761+00:00","extra":{}}
{"message":"Message AppBundle\\Message\\CurlRequest handled by AppBundle\\MessageHandler\\CurlRequestHandler::__invoke","context":{"message":{},"class":"AppBundle\\Message\\CurlRequest","handler":"AppBundle\\MessageHandler\\CurlRequestHandler::__invoke"},"level":200,"level_name":"INFO","channel":"messenger","datetime":"2022-01-31T18:54:15.293857+00:00","extra":{}}
{"message":"Error thrown while running command \"messenger:consume async\". Message: \"Serialization of 'Closure' is not allowed\"","context":{"exception":{"class":"Exception","message":"Serialization of 'Closure' is not allowed","code":0,"file":"/app/vendor/inspector-apm/inspector-symfony/src/Listeners/MessengerEventsSubscriber.php:81"},"command":"messenger:consume async","message":"Serialization of 'Closure' is not allowed"},"level":500,"level_name":"CRITICAL","channel":"console","datetime":"2022-01-31T18:54:15.439893+00:00","extra":{}}
18:54:15 CRITICAL  [console] Error thrown while running command "messenger:consume async". Message: "Serialization of 'Closure' is not allowed" ["exception" => Exception { …},"command" => "messenger:consume async","message" => "Serialization of 'Closure' is not allowed"]
{"message":"Command \"messenger:consume async\" exited with code \"1\"","context":{"command":"messenger:consume async","code":1},"level":100,"level_name":"DEBUG","channel":"console","datetime":"2022-01-31T18:54:15.458841+00:00","extra":{}}

In MessengerEventsSubscriber.php line 81:

  Serialization of 'Closure' is not allowed

framework:
    messenger:
        # Uncomment this (and the failed transport below) to send failed messages to this transport for later handling.
        failure_transport: failed
        transports:
            async: '%env(MESSENGER_TRANSPORT_DSN)%'
            failed: '%env(MESSENGER_TRANSPORT_DSN)%?queue_name=failed'
            #sync: 'sync://'
        routing:
            # Route your messages to the transports
            'AppBundle\Message\CurlRequest': async

#[AsMessageHandler]
class CurlRequestHandler
{

    public function __construct(private Curl $curl)
    {
    }

    public function __invoke(CurlRequest $message)
    {
        $this->curl->sendCurl($message->getUrl(), $message->getMethod(), $message->getContent(), $message->getApiKey());

    }

}

class CurlRequest
{

    private string $url;

    private string $method;

    private ?string $apiKey = null;

    private ?string $content = null;


    public function __construct(string $url,
        string $method,
        string $content=null,
        string $apiKey=null)
    {
        $this->url = $url;
        $this->method = $method;
        if($content) $this->content = $content;
        if($apiKey) $this->apiKey = $apiKey;
    }

    public function getContent(): ?string
    {
        return $this->content;
    }

    public function getUrl(): string
    {
        return $this->url;
    }

    public function getMethod(): string
    {
        return $this->method;
    }

    public function getApiKey(): ?string
    {
        return $this->apiKey;
    }

}

...
if($body) $body = \json_encode($body);
$this->bus->dispatch(new CurlRequest($url, $method, $body));