PHP code example of wangyan / rabbitmq-message

1. Go to this page and download the library: Download wangyan/rabbitmq-message 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/ */

wangyan / rabbitmq-message example snippets


 Queue\RabbitMQ\Providers\RabbitmqServiceProvider::class


php artisan vendor:publish


### 发布普通消息
$message = app(Message::class);
$message->publish([
    'name' => 'sunshine',
    'age' => 22,
], 'exchange', 'queue', 'direct');
return 'success';

### 发布延时消息
$delayMessage = app(DelayedMessage::class);
$delayMessage->delayPublish([
    'name' => 'Tang',
    'age' => 22,
], 'delay-exchange', 'delay-queue', 5000, 'direct');

return 'success';


### 消费普通消息
$message = app(Message::class);
$message->consumer('delay-queue', 'consumer_tag', 'delay-exchange', 'callbackFunc', 'direct');


### 消费延时消息
$delayMessage = app(DelayedMessage::class);
$delayMessage->delayConsumer('delay-queue', 'consumer_tag', 'delay-exchange', 'callbackFunc', 'direct');


function testConsume($message)
{
   var_dump(json_decode($message->body, true));
}