PHP code example of kontoulis / rabbitmq-laravel

    
        
<?php
require_once('vendor/autoload.php');

/* Start to develop here. Best regards https://php-download.com/ */

    

kontoulis / rabbitmq-laravel example snippets

RabbitMQ::setRoutingKey("myRoutingKey/queueName");

RabbitMQ::setExchange("myExchange")'

namespace Kontoulis\RabbitMQLaravel\Handlers;

use Kontoulis\RabbitMQLaravel\Message\Message;

/**
 * Class DefaultHandler
 * @package Kontoulis\RabbitMQLaravel\Handlers
 */
class DefaultHandler extends Handler{

    /**
     * Tries to process the incoming message.
     * @param Message $msg
     * @return int One of the possible return values defined as Handler
     * constants.
     */

    public function process(Message $msg)
    {
        return $this->handleSuccess($msg);

    }

    /**
     * @param $msg
     * @return int
     */
     protected function handleSuccess($msg)
       {
           var_dump($msg);
           /**
            * For more Handler return values see the parent class
            */
           return Handler::RV_SUCCEED_STOP;
       }
}

$handlers = ["\\App\\QueueHandlers\\MyHandler"];
\RabbitMQ::listenToQueue($handlers);

 php
Kontoulis\RabbitMQLaravel\RabbitMQLaravelServiceProvider::class,

 php
'RabbitMQ' => Kontoulis\RabbitMQLaravel\Facades\RabbitMQ::class,

 bash
$ php artisan vendor:publish

 php
// Single message
 
$msg = [
    "key1" => "value1", 
    "key2" => "value2"
    ];         
RabbitMQ::publishMesssage($msg);

// OR
RabbitMQ::publishMessage($msg, "myRoutingKey");

// Batch publishing

$messages = [
    [ "messsage_1_key1" => "value1", 
      "messsage_1_key2" => "value2"
    ],
    [
    "messsage_2_key1" => "value1", 
    "messsage_2_key2" => "value2"
    ]
];
RabbitMQ::publishBatch($messages);
// OR
RabbitMQ::publishBatch($messages, "myRoutingKey");