getQueues

@return array
438618
public function getQueues()
    {
        $informations = json_decode($this->query('GET', '/api/queues/'.$this->credentials['vhost']), true);
        $queues = array();
        foreach ($informations as $information) {
            $queues[] = $information['name'];
        }

        return $queues;
    }
87205
def get_queues(self):
        """"""
        res = self.celery.control.inspect().active_queues() or dict()
        return [result.get('name') for host in res.values() for result in host]
928034
public function getQueues()
    {
        $r = $this->db->executeQuery('select queue_id, queue_name from Queues');
        $queues = [];
        while ($row = $r->fetch()) {
            $queues[$row['queue_name']] = (int) $row['queue_id'];
        }

        $list = array_keys($queues);

        return $list;
    }
327687
public function ajaxGetQueues()
    {
        $data = Base::getJobsRepository()->orderBy('created_at', 'desc')->take(300)->get(['queue', 'payload', 'attempts', 'reserved', 'reserved_at', 'created_at']);

        foreach ($data as $d)
        {
            $obj = json_decode($d->payload);
            $d->payload = $obj->job;
            $d->data = json_encode($obj->data->data);
        }

        return \Response::json(array('data' => $data));
    }
755336
public function resolveQueues()
    {
        if (in_array('*', $this->queues)) {
            $queues = $this->redis->smembers(Queue::redisKey());
            is_array($queues) and sort($queues);
        } else {
            $queues = $this->queues;
        }

        if (!is_array($queues)) {
            $queues = array();
        }

        return $queues;
    }
819650
public function enqueueRecaptchaLibs()
    {
        if (($data = $this->didEnqueueLibs(__METHOD__))) {
            return $data; // Did this already.
        } // We only need to enqueue once.

        $data = [
            'scripts' => [
                'recaptcha' => [
                    'async' => true,
                    'sri'   => '', // No SRI, updated by Google.
                    'url'   => '//www.google.com/recaptcha/api.js',
                ],
            ],
        ];
        return $this->enqueueLibs(__METHOD__, $data);
    }
485682
public function get() {
        $num_conns = count($this->queue);
        if ($num_conns < $this->pool_size) {
            try {
                $this->make_conn();
            } catch (NoServerAvailable $e) {
                if ($num_conns == 0)
                    throw $e;
            }
        }
        return array_shift($this->queue);
    }
224055
public function getReplies()
    {
        $this->channel
            ->basic_consume(
                $this->queueName,
                $this->queueName,
                false,
                true,
                false,
                false,
                array($this, 'processMessage')
            );

        while (count($this->replies) < $this->requests) {
            $this->channel
                ->wait(null, false, $this->requestTimeout);
        }

        $this->channel
            ->basic_cancel($this->queueName);

        return $this->replies;
    }
10951
public function getQueueConfigurationScopes()
    {
        // cache of seen, unique AMQP configurations
        $configurations = array();
        // list of stores to produce unique AMQP configuration
        $uniqueStores = array();
        foreach (Mage::app()->getStores(true) as $store) {
            $amqpConfig = $this->getStoreLevelAmqpConfigurations($store);
            if (!in_array($amqpConfig, $configurations, true)) {
                $configurations[] = $amqpConfig;
                $uniqueStores[] = $store;
            }
        }
        return $uniqueStores;
    }
197874
public function queue()
    {
        if (is_null($this->queue)) {
            $this->queue = app(Queue::class);
        }

        return $this->queue;
    }
691459
protected function getFailedJobs()
	{
		$results = [];

		foreach ($this->laravel['queue.failer']->all() as $failed) {
			$results[] = $this->parseFailedJob((array) $failed);
		}

		return array_filter($results);
	}
1367458
public function getListQueued()
    {
        $params = ['status' => 'queued'];

        $response = $this->client->fetch(
            $this->uri,
            $params
        );

        $queuedCallUuids = $response->getContent()['calls'];

        return $queuedCallUuids;
    }
629891
protected function getFailedJobs()
    {
        $failed = $this->app['queue.failer']->all();

        return collect($failed)->map(function ($failed) {
            return $this->parseFailedJob((array) $failed);
        })->filter()->all();
    }
568084
public function getSnippets()
    {
        $snippets = [];
        foreach ($this->app['asset.queue.snippet']->getQueue() as $snippet) {
            $snippets[] = (string) $snippet;
        }

        return $snippets;
    }
348439
protected function getQueue()
	{
		if (isset($this->meta)) return $this->meta;

		return $this->meta = $this->flyphp['queue']->getIron()->getQueue($this->argument('queue'));
	}
1240754
public function enqueueNoUiSliderLibs()
    {
        if (($data = $this->didEnqueueLibs(__METHOD__))) {
            return $data; // Did this already.
        } // We only need to enqueue once.

        $data = [
            'styles' => [
                'no-ui-slider' => [
                    'version' => '9.2.0',
                    'url'     => '//cdnjs.cloudflare.com/ajax/libs/noUiSlider/%1$s/nouislider.min.css',
                ],
            ],
            'scripts' => [
                'no-ui-wnumb' => [
                    'version' => '1.1.0',
                    'url'     => '//cdnjs.cloudflare.com/ajax/libs/wnumb/%1$s/wNumb.min.js',
                ],
                'no-ui-slider' => [
                    'version' => '9.2.0',
                    'deps'    => ['no-ui-wnumb'],
                    'url'     => '//cdnjs.cloudflare.com/ajax/libs/noUiSlider/%1$s/nouislider.min.js',
                ],
            ],
        ];
        return $this->enqueueLibs(__METHOD__, $data);
    }
1023173
protected function executeQueuedJobs()
    {
        $returnValues = [];
        while ($resumeCommand = array_shift($this->queue)) {
            $returnValues[] = $resumeCommand();
        }

        return array_shift($returnValues);
    }