Support for channel->basic_qos about laravel-amqp HOT 5 CLOSED

private $prefetch_count = 1;


public function setPrefetchCount($prefetch_count)
{
    $this->prefetch_count = $prefetch_count;
}

public function consume($queue, Closure $callback, $properties = [])
{
    // If array, binding only first element, then the rest
    $routing_keys = [];
    if (is_array($properties['routing']))
    {
        $routing_keys = $properties['routing'];
        $properties['routing'] = array_shift($routing_keys);
    }

    $properties['queue'] = $queue;
    /* @var Consumer $consumer */
    $consumer = app()->make('Bschmitt\Amqp\Consumer');
    $consumer
        ->mergeProperties($properties)
        ->setup();

    // Binding queue with rest of routing keys
    foreach($routing_keys as $routing_key)
    {
        $consumer->channel->queue_bind($queue ?: $consumer->queueInfo[0], $consumer->getProperty('exchange'), $routing_key);
    }

    // Setting prefetch count
    $consumer->getChannel()->basic_qos(null, $this->prefetch_count, null);

    $consumer->consume($queue, $callback);
    Request::shutdown($consumer->getChannel(), $consumer->getConnection());
}