Skip to content

Instantly share code, notes, and snippets.

@ronan-gloo

ronan-gloo/multiples.queues.php

Last active February 2, 2017 19:30
Show Gist options
  • Save ronan-gloo/9cdc7ff20574ea662a9dae694b926adb to your computer and use it in GitHub Desktop.
Save ronan-gloo/9cdc7ff20574ea662a9dae694b926adb to your computer and use it in GitHub Desktop.
Download ZIP
Raw
multiples.queues.php
<?php
$connection = new \AMQPConnection([
'host' => '127.0.0.1',
'login' => 'guest',
'password' => 'guest',
'port' => 5672,
'vhost' => '/',
]);
$connection->connect();
$channel = new \AMQPChannel($connection);
$consumer = function(\AMQPEnvelope $message, \AMQPQueue $queue) {
echo $queue->getName() . PHP_EOL; // always deliver queue2 : no ack possible on queue1
};
$queue = new \AMQPQueue($channel);
$queue->setName('queue1');
$queue->declareQueue();
$queue->consume();
$queue = new \AMQPQueue($channel);
$queue->setName('queue2');
$queue->declareQueue();
$queue->consume($consumer);
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment