PHP code example of makaronnik / amphp-rabbitmq-manager
1. Go to this page and download the library: Download makaronnik/amphp-rabbitmq-manager library. Choose the download type require.
2. Extract the ZIP file and open the index.php.
3. Add this code to the index.php.
<?php
require_once('vendor/autoload.php');
/* Start to develop here. Best regards https://php-download.com/ */
makaronnik / amphp-rabbitmq-manager example snippets
use Amp\Loop;
use PHPinnacle\Ridge\Client;
use PHPinnacle\Ridge\Channel;
use PHPinnacle\Ridge\Message;
use Makaronnik\RabbitManager\Manager;
use Cspray\Labrador\AsyncEvent\AmpEventEmitter;
use Cspray\Labrador\AsyncEvent\StandardEventFactory;
$manager = new Manager(
client: Client::create($dsn),
pendingConnectionQueue: new SplQueue(),
maxAttempts: 30,
eventEmitter: new AmpEventEmitter(),
eventFactory: new StandardEventFactory()
);
$channel = yield $manager->getChanel('testChannel');
try {
yield $channel->queueDeclare('basic_queue', false, false, false, true);
for ($i = 0; $i < 10; $i++) {
yield $channel->publish("test_$i", '', 'basic_queue');
}
yield $channel->consume(function (Message $message, Channel $channel) {
echo $message->content . \PHP_EOL;
yield $channel->ack($message);
}, 'basic_queue');
} catch (Throwable $exception) {
yield $manager->handleConnectionBreak($exception);
}
yield $manager->disconnect('Bye!');
});