Update AmqpTrait.php

webtoucher · Jul 24, 2014 · 5fb0c1d · 5fb0c1d
1 parent bad81b4
commit 5fb0c1d
Showing 1 changed file with 3 additions and 2 deletions.
diff --git a/controllers/AmqpTrait.php b/controllers/AmqpTrait.php
@@ -45,13 +45,14 @@ public function getConnection()
     /**
      * Returns AMQP channel.
      *
+     * @param string $channel_id
      * @return AMQPChannel
      */
-    public function getChannel()
+    public function getChannel($channel_id = null)
     {
         if (empty($this->amqp)) {
             $this->amqp = Yii::$app->amqp;
         }
-        return $this->amqp->getChannel();
+        return $this->amqp->getChannel($channel_id);
     }
 }