AmqpMessage delay method has been added. Updated namespace. Added possibility to pass dependencies via constructor. Composer json actualization.

Author: devyk

.gitignore

@@ -0,0 +1 @@
+vendor/

components/Amqp.php

@@ -5,11 +5,10 @@
  * @license https://github.com/webtoucher/yii2-amqp/blob/master/LICENSE.md
  */
 
-namespace webtoucher\amqp\components;
+namespace devyk\amqp\components;
 
 use yii\base\Component;
 use yii\base\Exception;
-use yii\helpers\Inflector;
 use yii\helpers\Json;
 use PhpAmqpLib\Channel\AMQPChannel;
 use PhpAmqpLib\Connection\AMQPConnection;

components/AmqpInterpreter.php

@@ -5,7 +5,7 @@
  * @license https://github.com/webtoucher/yii2-amqp/blob/master/LICENSE.md
  */
 
-namespace webtoucher\amqp\components;
+namespace devyk\amqp\components;
 
 use yii\helpers\Console;
 

components/AmqpMessage.php

@@ -0,0 +1,34 @@
+<?php
+
+namespace devyk\amqp\components;
+
+use PhpAmqpLib\Message\AMQPMessage as BaseAMQPMessage;
+use PhpAmqpLib\Wire\AMQPTable;
+
+class AmqpMessage extends BaseAMQPMessage
+{
+    /**
+     * @param array $body
+     * @return $this
+     */
+    public function setBody($body)
+    {
+        parent::setBody(json_encode($body));
+        return $this;
+    }
+
+    /**
+     * @param $delay
+     * @return $this
+     */
+    public function setDelay($delay)
+    {
+        $this->set(
+            'application_headers',
+            new AMQPTable([
+                'x-delay' => $delay * 1000
+            ])
+        );
+        return $this;
+    }
+}

components/AmqpTrait.php

@@ -5,13 +5,11 @@
  * @license https://github.com/webtoucher/yii2-amqp/blob/master/LICENSE.md
  */
 
-namespace webtoucher\amqp\components;
+namespace devyk\amqp\components;
 
-use Yii;
+use yii;
 use PhpAmqpLib\Channel\AMQPChannel;
 use PhpAmqpLib\Connection\AMQPConnection;
-use webtoucher\amqp\components\Amqp;
-use webtoucher\commands\Controller;
 
 
 /**
@@ -26,7 +24,7 @@
 trait AmqpTrait
 {
     /**
-     * @var Amqp
+     * @var \devyk\amqp\components\Amqp
      */
     protected $amqpContainer;
 
@@ -40,7 +38,7 @@ trait AmqpTrait
     /**
      * Returns AMQP object.
      *
-     * @return Amqp
+     * @return \devyk\amqp\components\Amqp
      */
     public function getAmqp()
     {

composer.json

@@ -17,12 +17,13 @@
     ],
     "require": {
         "php": ">=5.3.0",
+        "yiisoft/yii2": "2.0.*",
         "php-amqplib/php-amqplib": "~2.0",
         "webtoucher/yii2-commands": "*"
     },
     "autoload": {
         "psr-4": {
-            "webtoucher\\amqp\\": ""
+            "devyk\\amqp\\": ""
         }
     }
 }