RabbitMQ Publisher-Subscriber (https://github.com/videlalvaro/php-amqplib)

rabbitmq.publisher.php

<?php

use PhpAmqpLib\Connection\AMQPConnection;
use PhpAmqpLib\Message\AMQPMessage;

// connect
$connection = new AMQPConnection('localhost', 5672, 'guest', 'guest');

// create channel
$channel = $connection->channel();

// declare exchange
$channel->exchange_declare('ExchangeName', 'topic', false, false, false);

// send message
$message = new AMQPMessage('say hello at ' . date('Y-m-d H:i:s'), array(
    'delivery_mode' => 2,
));

$channel->basic_publish($message, 'ExchangeName', 'errors.warn');

// close
$channel->close();
$connection->close();

rabbitmq.subscriber.php

<?php

use PhpAmqpLib\Connection\AMQPConnection;
use PhpAmqpLib\Message\AMQPMessage;

// connect
$connection = new AMQPConnection('localhost', 5672, 'guest', 'guest');

// create channel
$channel = $connection->channel();

// declare exchange
$channel->exchange_declare('ExchangeName', 'topic', false, false, false);

list($queueName,,) = $channel->queue_declare('', false, true);
echo 'Queue Name: ' . $queueName . PHP_EOL;

$channel->queue_bind($queueName, 'ExchangeName', '*.warn');

// redister callback
$channel->basic_consume($queueName, '', false, false, true, false, function(AMQPMessage $msg) {
    // print message
    echo 'Received: ' . $msg->body . PHP_EOL;
});

// start loop
echo 'Start loop' . PHP_EOL;
while(count($channel->callbacks)) {
    $channel->wait();
}