PHP code example of greenhat616 / laravel-amqp
1. Go to this page and download the library: Download greenhat616/laravel-amqp 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' );
greenhat616 / laravel-amqp example snippets
return [
'use' => 'production' ,
'properties' => [
'production' => [
'host' => 'localhost' ,
'port' => 5672 ,
'username' => 'username' ,
'password' => 'password' ,
'vhost' => '/' ,
'exchange' => 'amq.topic' ,
'exchange_type' => 'topic' ,
'consumer_tag' => 'consumer' ,
'ssl_options' => [],
'connect_options' => [],
'queue_properties' => ['x-ha-policy' => ['S' , 'all' ]],
'exchange_properties' => [],
'timeout' => 0
],
],
];
$app->configure('amqp' );
$app->register(Bschmitt\Amqp\LumenServiceProvider::class);
$app->withFacades(true , [
'Bschmitt\Amqp\Facades\Amqp' => 'Amqp' ,
]);
'Bschmitt\Amqp\AmqpServiceProvider' ,
'Amqp' => 'Bschmitt\Amqp\Facades\Amqp' ,
Amqp::publish('routing-key' , 'message' );
Amqp::publish('routing-key' , 'message' , ['queue' => 'queue-name' ]);
Amqp::publish('routing-key' , 'message' , ['exchange' => 'amq.direct' ]);
Amqp::consume('queue-name' , function ($message, $resolver) {
var_dump($message->body);
$resolver->acknowledge($message);
$resolver->stopWhenProcessed();
});
Amqp::consume('queue-name' , function ($message, $resolver) {
var_dump($message->body);
$resolver->acknowledge($message);
});
Amqp::consume('queue-name' , function ($message, $resolver) {
var_dump($message->body);
$resolver->acknowledge($message);
}, [
'timeout' => 2 ,
'vhost' => 'vhost3'
]);
\Amqp::publish('' , 'message' , [
'exchange_type' => 'fanout' ,
'exchange' => 'amq.fanout' ,
]);
\Amqp::consume('' , function ($message, $resolver) {
var_dump($message->body);
$resolver->acknowledge($message);
}, [
'routing' => '' ,
'exchange' => 'amq.fanout' ,
'exchange_type' => 'fanout' ,
'queue_force_declare' => true ,
'queue_exclusive' => true ,
'persistent' => true
batch
$ php composer update
$ php composer