A Complete Guide on Configure & Use RabbitMQ in Magento 2

sudo apt-get update

sudo apt-get install rabbitmq-server

sudo systemctl start rabbitmq-server
sudo systemctl enable rabbitmq-server

sudo rabbitmqctl add_user magento_user magento_password
sudo rabbitmqctl add_vhost magento_vhost
sudo rabbitmqctl set_permissions -p magento_vhost magento_user ".*" ".*" ".*"

'queue' => [
         	'amqp' => [
                	 'host' => 'yourhost.yourdomain.com',
 'port' => '5672',
 'user' => 'magento_user',
 'password' => 'magento_password',
 'virtualhost' => '/'
 	 ]
 ],

<?php
\Magento\Framework\Component\ComponentRegistrar::register(
    \Magento\Framework\Component\ComponentRegistrar::MODULE,
    'Vendor_Module',
    __DIR__
);

<?xml version="1.0"?>
<config xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:noNamespaceSchemaLocation="urn:magento:framework:Module/etc/module.xsd">
    <module name="Vendor_Module" setup_version="1.0.0">
        <sequence>
            <module name="Magento_Amqp"/>
        </sequence>
    </module>
</config>

<?xml version="1.0"?>
<config xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:noNamespaceSchemaLocation="urn:magento:framework-message-queue:etc/queue_topology.xsd">
    <topology name="example.queue.topology">
        <exchange name="example.exchange" type="topic" connection="amqp">
            <binding id="example.binding" topic="example.topic"/>
        </exchange>
        <queue name="example.queue" connection="amqp">
            <binding id="example.queue.binding" exchange="example.exchange" topic="example.topic"/>
        </queue>
    </topology>
</config>

<?xml version="1.0"?>
<config xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:noNamespaceSchemaLocation="urn:magento:framework-message-queue:etc/queue_consumer.xsd">
    <consumer name="example.consumer" queue="example.queue" connection="amqp" consumerInstance="Vendor\Module\Model\ExampleConsumer">
        <cron expression="* * * * *"/>
    </consumer>
</config>

<?xml version="1.0"?>
<config xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:noNamespaceSchemaLocation="urn:magento:framework-message-queue:etc/queue_publisher.xsd">
    <publisher name="example.publisher" topic="example.topic" connection="amqp"/>
</config>

<?php
namespace Vendor\Module\Model;

use Magento\Framework\MessageQueue\PublisherInterface;

class ExamplePublisher
{
    protected $publisher;

    public function __construct(PublisherInterface $publisher)
    {
        $this->publisher = $publisher;
    }

    public function publish($message)
    {
        $this->publisher->publish('example.topic', $message);
    }
}

<?php
namespace Vendor\Module\Model;

class ExampleConsumer
{
    public function process($message)
    {
        // Process the message
        echo "Received message: " . $message . PHP_EOL;
    }
}

<?php
namespace Vendor\Module\Console\Command;

use Magento\Framework\Console\Cli;
use Symfony\Component\Console\Command\Command;
use Symfony\Component\Console\Input\InputInterface;
use Symfony\Component\Console\Output\OutputInterface;
use Vendor\Module\Model\ExamplePublisher;

class PublishMessageCommand extends Command
{
    protected $publisher;

    public function __construct(ExamplePublisher $publisher)
    {
        $this->publisher = $publisher;
        parent::__construct();
    }

    protected function configure()
    {
        $this->setName('vendor:module:publish')
            ->setDescription('Publish a message to the RabbitMQ queue');
        parent::configure();
    }

    protected function execute(InputInterface $input, OutputInterface $output)
    {
        $this->publisher->publish('Hello, RabbitMQ!');
        $output->writeln('<info>Message published successfully</info>');
        return Cli::RETURN_SUCCESS;
    }
}

<?xml version="1.0"?>
<config xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:noNamespaceSchemaLocation="urn:magento:framework:ObjectManager/etc/config.xsd">
    <type name="Magento\Framework\Console\CommandList">
        <arguments>
            <argument name="commands" xsi:type="array">
                <item name="vendor_module_publish" xsi:type="object">Vendor\Module\Console\Command\PublishMessageCommand</item>
            </argument>
        </arguments>
    </type>
</config>

bin/magento module:enable Vendor_Module

bin/magento setup:upgrade

bin/magento setup:di:compile

bin/magento cache:clean

bin/magento vendor:module:publish