ProduceMessageCommand.php

<?php

namespace Enqueue\Symfony\Client;

use Enqueue\Client\ProducerInterface;
use Symfony\Component\Console\Command\Command;
use Symfony\Component\Console\Input\InputArgument;
use Symfony\Component\Console\Input\InputInterface;
use Symfony\Component\Console\Output\OutputInterface;

class ProduceMessageCommand extends Command
{
    protected static $defaultName = 'enqueue:produce';

    /**
     * @var ProducerInterface
     */
    private $producer;

    /**
     * @param ProducerInterface $producer
     */
    public function __construct(ProducerInterface $producer)
    {
        parent::__construct(static::$defaultName);

        $this->producer = $producer;
    }

    /**
     * {@inheritdoc}
     */
    protected function configure()
    {
        $this
            ->setAliases(['enq:p'])
            ->setDescription('A command to send a message to topic')
            ->addArgument('topic', InputArgument::REQUIRED, 'A topic to send message to')
            ->addArgument('message', InputArgument::REQUIRED, 'A message to send')
        ;
    }

    /**
     * {@inheritdoc}
     */
    protected function execute(InputInterface $input, OutputInterface $output)
    {
        $this->producer->sendEvent(
            $input->getArgument('topic'),
            $input->getArgument('message')
        );

        $output->writeln('Message is sent');
    }
}