Merge pull request #167 from Gnucki/master

videlalvaro · videlalvaro · commit f21d86981294 · 2014-03-17T15:38:17.000+01:00
Use channel accessor
diff --git a/RabbitMq/Consumer.php b/RabbitMq/Consumer.php
@@ -54,7 +54,7 @@ public function consume($msgAmount)
      */
     public function purge()
     {
-        $this->ch->queue_purge($this->queueOptions['name'], true);
+        $this->getChannel()->queue_purge($this->queueOptions['name'], true);
     }
 
     public function processMessage(AMQPMessage $msg)
@@ -97,4 +97,4 @@ protected function isRamAlmostOverloaded()
             return false;
         }
     }
-}
+}

Original file line number	Diff line number	Diff line change
`@@ -54,7 +54,7 @@ public function consume($msgAmount)`
`54`	`54`	`*/`
`55`	`55`	`public function purge()`
`56`	`56`	`{`
`57`		`- $this->ch->queue_purge($this->queueOptions['name'], true);`
	`57`	`+ $this->getChannel()->queue_purge($this->queueOptions['name'], true);`
`58`	`58`	`}`
`59`	`59`
`60`	`60`	`public function processMessage(AMQPMessage $msg)`
`@@ -97,4 +97,4 @@ protected function isRamAlmostOverloaded()`
`97`	`97`	`return false;`
`98`	`98`	`}`
`99`	`99`	`}`
`100`		`-}`
	`100`	`+}`