neiluJ

<?php

namespace App\Entity;

use Doctrine\ORM\Mapping as ORM;
use ApiPlatform\Core\Annotation\ApiResource;

/**
 * Todo
 *

neiluJ

<?php

namespace App\Entity;

use Doctrine\ORM\Mapping as ORM;
use ApiPlatform\Core\Annotation\ApiResource;

/**
 * Todolist
 *

neiluJ

# config/packages/messenger.yaml
framework:
    messenger:
        routing:
            'App\Message\CreateArchiveMessage': amqp
            'App\Message\SendEmailMessage': amqp_email

neiluJ

php bin/console messenger:consume-messages amqp

neiluJ

# config/packages/messenger.yaml
framework:
    messenger:
        transports:
            amqp: "amqp://guest:guest@localhost:5672/%2f/messages"

neiluJ

<?php
namespace App\Controller;

use App\Message\CreateArchiveMessage;
use Symfony\Bundle\FrameworkBundle\Controller\AbstractController;
use Symfony\Component\Messenger\MessageBusInterface;

class CreateArchiveController extends AbstractController
{
    public function index(MessageBusInterface $bus)

neiluJ

<?php
namespace App\MessageHandler;

use App\Message\CreateArchiveMessage;
use Symfony\Component\Messenger\Handler\MessageHandlerInterface;

class CreateArchiveHandler implements MessageHandlerInterface
{
    // use constructor + autowiring to inject required services

neiluJ

<?php
namespace App\Message;

class CreateArchiveMessage
{
    public $userId;

    public function __construct(int $userId)
    {
        $this->userId = $userId;

neiluJ

<?php


/**
 * Class HookMe
 *
 * Hooks wrapper class
 */
class HookMe
{

neiluJ

<?php
namespace HelloApp;

use Fwk\Core\Application;
use Fwk\Core\Action\ProxyFactory;

$app    = new Application('HelloApp');
$app->register('Hello', ProxyFactory::factory(function($name = null) { 
    return 'Hello '. ($name === null ? '!' : $name); 
}))