namespace App\Message;

class SmsNotification
{
    public function __construct(
        private string $content,
    ) {}

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

namespace App\MessageHandler;

use App\Message\SmsNotification;
use Symfony\Component\Messenger\Attribute\AsMessageHandler;

#[AsMessageHandler]
class SmsNotificationHandler
{
    public function __invoke(SmsNotification $message): void
    {
        // Process the message
    }
}

use Symfony\Component\Messenger\MessageBusInterface;

class MyController
{
    public function __construct(private MessageBusInterface $bus) {}

    public function action(): Response
    {
        $this->bus->dispatch(new SmsNotification('Hello!'));
        return new Response('Message sent');
    }
}

framework:
    messenger:
        transports:
            async: "%env(MESSENGER_TRANSPORT_DSN)%"
            failed: 'doctrine://default?queue_name=failed'

        failure_transport: failed

        routing:
            'App\Message\SmsNotification': async

# RabbitMQ (AMQP)
MESSENGER_TRANSPORT_DSN=amqp://guest:guest@localhost:5672/%2f/messages

# Doctrine (database)
MESSENGER_TRANSPORT_DSN=doctrine://default

# Redis
MESSENGER_TRANSPORT_DSN=redis://localhost:6379/messages

# Synchronous
MESSENGER_TRANSPORT_DSN=sync://

# Basic consumption
php bin/console messenger:consume async

# With limits
php bin/console messenger:consume async --limit=10 --time-limit=3600 --memory-limit=128M

# Multiple transports (priority order)
php bin/console messenger:consume async_high async_low

# Verbose output
php bin/console messenger:consume async -vv

use Symfony\Component\Messenger\Stamp\DelayStamp;
use Symfony\Component\Messenger\Stamp\TransportNamesStamp;

// Delay message by 5 seconds
$bus->dispatch(new SmsNotification('Hello'), [new DelayStamp(5000)]);

// Override transport at runtime
$bus->dispatch(new SmsNotification('Hello'), [new TransportNamesStamp(['sync'])]);

framework:
    messenger:
        transports:
            async:
                dsn: '%env(MESSENGER_TRANSPORT_DSN)%'
                retry_strategy:
                    max_retries: 3
                    delay: 1000
                    multiplier: 2
                    max_delay: 60000

php bin/console messenger:failed:show          # View failed messages
php bin/console messenger:failed:retry 20 --force  # Retry specific message
php bin/console messenger:failed:remove 20     # Remove failed message

#[AsMessageHandler(bus: 'messenger.bus.command')]
class CreateUserHandler
{
    public function __invoke(CreateUserCommand $message): void { }
}

use Symfony\Component\Messenger\Attribute\AsMessage;

#[AsMessage('async')]
class SmsNotification { }