Permalink
Browse files

made QueueChannel use INF\Queue\Queue

  • Loading branch information...
1 parent 09356d7 commit 03682fa8417728c427f456d8efb499fbb725ab4b @tidal committed Jul 22, 2011
Showing with 4 additions and 2 deletions.
  1. +4 −2 src/Channel/QueueChannel.php
@@ -37,9 +37,11 @@ class QueueChannel
* @param $capacity
* @return
*/
- public function __construct($capacity = -1){
+ public function __construct($capacity = -1, PEIP\INF\Queue\Queue $queue = NULL){
$this->setCapacity((int)$capacity);
- $this->queue = new SplQueue();
+ $this->queue = $queue
+ ? $queue
+ : new \PEIP\Queue\Queue;
}

0 comments on commit 03682fa

Please sign in to comment.