http://git-wip-us.apache.org/repos/asf/airavata-php-gateway/blob/80fd786e/vendor/laravel/framework/src/Illuminate/Pagination/composer.json ---------------------------------------------------------------------- diff --git a/vendor/laravel/framework/src/Illuminate/Pagination/composer.json b/vendor/laravel/framework/src/Illuminate/Pagination/composer.json deleted file mode 100755 index 432459c..0000000 --- a/vendor/laravel/framework/src/Illuminate/Pagination/composer.json +++ /dev/null @@ -1,30 +0,0 @@ -{ - "name": "illuminate/pagination", - "license": "MIT", - "authors": [ - { - "name": "Taylor Otwell", - "email": "[email protected]" - } - ], - "require": { - "php": ">=5.4.0", - "illuminate/http": "4.2.*", - "illuminate/support": "4.2.*", - "illuminate/view": "4.2.*", - "symfony/http-foundation": "2.5.*", - "symfony/translation": "2.5.*" - }, - "autoload": { - "psr-0": { - "Illuminate\\Pagination": "" - } - }, - "target-dir": "Illuminate/Pagination", - "extra": { - "branch-alias": { - "dev-master": "4.2-dev" - } - }, - "minimum-stability": "dev" -}
http://git-wip-us.apache.org/repos/asf/airavata-php-gateway/blob/80fd786e/vendor/laravel/framework/src/Illuminate/Pagination/views/simple.php ---------------------------------------------------------------------- diff --git a/vendor/laravel/framework/src/Illuminate/Pagination/views/simple.php b/vendor/laravel/framework/src/Illuminate/Pagination/views/simple.php deleted file mode 100755 index 3a13482..0000000 --- a/vendor/laravel/framework/src/Illuminate/Pagination/views/simple.php +++ /dev/null @@ -1,15 +0,0 @@ -<?php - $presenter = new Illuminate\Pagination\BootstrapPresenter($paginator); - - $trans = $environment->getTranslator(); -?> - -<?php if ($paginator->getLastPage() > 1): ?> - <ul class="pager"> - <?php - echo $presenter->getPrevious($trans->trans('pagination.previous')); - - echo $presenter->getNext($trans->trans('pagination.next')); - ?> - </ul> -<?php endif; ?> http://git-wip-us.apache.org/repos/asf/airavata-php-gateway/blob/80fd786e/vendor/laravel/framework/src/Illuminate/Pagination/views/slider-3.php ---------------------------------------------------------------------- diff --git a/vendor/laravel/framework/src/Illuminate/Pagination/views/slider-3.php b/vendor/laravel/framework/src/Illuminate/Pagination/views/slider-3.php deleted file mode 100755 index 5757e6c..0000000 --- a/vendor/laravel/framework/src/Illuminate/Pagination/views/slider-3.php +++ /dev/null @@ -1,9 +0,0 @@ -<?php - $presenter = new Illuminate\Pagination\BootstrapPresenter($paginator); -?> - -<?php if ($paginator->getLastPage() > 1): ?> - <ul class="pagination"> - <?php echo $presenter->render(); ?> - </ul> -<?php endif; ?> http://git-wip-us.apache.org/repos/asf/airavata-php-gateway/blob/80fd786e/vendor/laravel/framework/src/Illuminate/Pagination/views/slider.php ---------------------------------------------------------------------- diff --git a/vendor/laravel/framework/src/Illuminate/Pagination/views/slider.php b/vendor/laravel/framework/src/Illuminate/Pagination/views/slider.php deleted file mode 100755 index 2344162..0000000 --- a/vendor/laravel/framework/src/Illuminate/Pagination/views/slider.php +++ /dev/null @@ -1,11 +0,0 @@ -<?php - $presenter = new Illuminate\Pagination\BootstrapPresenter($paginator); -?> - -<?php if ($paginator->getLastPage() > 1): ?> - <div class="pagination"> - <ul> - <?php echo $presenter->render(); ?> - </ul> - </div> -<?php endif; ?> http://git-wip-us.apache.org/repos/asf/airavata-php-gateway/blob/80fd786e/vendor/laravel/framework/src/Illuminate/Queue/BeanstalkdQueue.php ---------------------------------------------------------------------- diff --git a/vendor/laravel/framework/src/Illuminate/Queue/BeanstalkdQueue.php b/vendor/laravel/framework/src/Illuminate/Queue/BeanstalkdQueue.php deleted file mode 100755 index 0fe29f6..0000000 --- a/vendor/laravel/framework/src/Illuminate/Queue/BeanstalkdQueue.php +++ /dev/null @@ -1,142 +0,0 @@ -<?php namespace Illuminate\Queue; - -use Pheanstalk_Job; -use Pheanstalk_Pheanstalk as Pheanstalk; -use Illuminate\Queue\Jobs\BeanstalkdJob; - -class BeanstalkdQueue extends Queue implements QueueInterface { - - /** - * The Pheanstalk instance. - * - * @var \Pheanstalk_Pheanstalk - */ - protected $pheanstalk; - - /** - * The name of the default tube. - * - * @var string - */ - protected $default; - - /** - * The "time to run" for all pushed jobs. - * - * @var int - */ - protected $timeToRun; - - /** - * Create a new Beanstalkd queue instance. - * - * @param \Pheanstalk_Pheanstalk $pheanstalk - * @param string $default - * @param int $timeToRun - * @return void - */ - public function __construct(Pheanstalk $pheanstalk, $default, $timeToRun) - { - $this->default = $default; - $this->timeToRun = $timeToRun; - $this->pheanstalk = $pheanstalk; - } - - /** - * Push a new job onto the queue. - * - * @param string $job - * @param mixed $data - * @param string $queue - * @return mixed - */ - public function push($job, $data = '', $queue = null) - { - return $this->pushRaw($this->createPayload($job, $data), $queue); - } - - /** - * Push a raw payload onto the queue. - * - * @param string $payload - * @param string $queue - * @param array $options - * @return mixed - */ - public function pushRaw($payload, $queue = null, array $options = array()) - { - return $this->pheanstalk->useTube($this->getQueue($queue))->put( - $payload, Pheanstalk::DEFAULT_PRIORITY, Pheanstalk::DEFAULT_DELAY, $this->timeToRun - ); - } - - /** - * Push a new job onto the queue after a delay. - * - * @param \DateTime|int $delay - * @param string $job - * @param mixed $data - * @param string $queue - * @return mixed - */ - public function later($delay, $job, $data = '', $queue = null) - { - $payload = $this->createPayload($job, $data); - - $pheanstalk = $this->pheanstalk->useTube($this->getQueue($queue)); - - return $pheanstalk->put($payload, Pheanstalk::DEFAULT_PRIORITY, $this->getSeconds($delay), $this->timeToRun); - } - - /** - * Pop the next job off of the queue. - * - * @param string $queue - * @return \Illuminate\Queue\Jobs\Job|null - */ - public function pop($queue = null) - { - $queue = $this->getQueue($queue); - - $job = $this->pheanstalk->watchOnly($queue)->reserve(0); - - if ($job instanceof Pheanstalk_Job) - { - return new BeanstalkdJob($this->container, $this->pheanstalk, $job, $queue); - } - } - - /** - * Delete a message from the Beanstalk queue. - * - * @param string $queue - * @param string $id - * @return void - */ - public function deleteMessage($queue, $id) - { - $this->pheanstalk->useTube($this->getQueue($queue))->delete($id); - } - - /** - * Get the queue or return the default. - * - * @param string|null $queue - * @return string - */ - public function getQueue($queue) - { - return $queue ?: $this->default; - } - - /** - * Get the underlying Pheanstalk instance. - * - * @return \Pheanstalk_Pheanstalk - */ - public function getPheanstalk() - { - return $this->pheanstalk; - } - -} http://git-wip-us.apache.org/repos/asf/airavata-php-gateway/blob/80fd786e/vendor/laravel/framework/src/Illuminate/Queue/Capsule/Manager.php ---------------------------------------------------------------------- diff --git a/vendor/laravel/framework/src/Illuminate/Queue/Capsule/Manager.php b/vendor/laravel/framework/src/Illuminate/Queue/Capsule/Manager.php deleted file mode 100644 index a182ede..0000000 --- a/vendor/laravel/framework/src/Illuminate/Queue/Capsule/Manager.php +++ /dev/null @@ -1,182 +0,0 @@ -<?php namespace Illuminate\Queue\Capsule; - -use Illuminate\Queue\QueueManager; -use Illuminate\Container\Container; -use Illuminate\Queue\QueueServiceProvider; -use Illuminate\Support\Traits\CapsuleManagerTrait; - -class Manager { - - use CapsuleManagerTrait; - - /** - * The queue manager instance. - * - * @var \Illuminate\Queue\QueueManager - */ - protected $manager; - - /** - * Create a new queue capsule manager. - * - * @param \Illuminate\Container\Container $container - * @return void - */ - public function __construct(Container $container = null) - { - $this->setupContainer($container); - - // Once we have the container setup, we will setup the default configuration - // options in the container "config" bindings. This just makes this queue - // manager behave correctly since all the correct binding are in place. - $this->setupDefaultConfiguration(); - - $this->setupManager(); - - $this->registerConnectors(); - } - - /** - * Setup the default queue configuration options. - * - * @return void - */ - protected function setupDefaultConfiguration() - { - $this->container['config']['queue.default'] = 'default'; - } - - /** - * Build the queue manager instance. - * - * @return void - */ - protected function setupManager() - { - $this->manager = new QueueManager($this->container); - } - - /** - * Register the default connectors that the component ships with. - * - * @return void - */ - protected function registerConnectors() - { - $provider = new QueueServiceProvider($this->container); - - $provider->registerConnectors($this->manager); - } - - /** - * Get a connection instance from the global manager. - * - * @param string $connection - * @return \Illuminate\Queue\QueueInterface - */ - public static function connection($connection = null) - { - return static::$instance->getConnection($connection); - } - - /** - * Push a new job onto the queue. - * - * @param string $job - * @param mixed $data - * @param string $queue - * @param string $connection - * @return mixed - */ - public static function push($job, $data = '', $queue = null, $connection = null) - { - return static::$instance->connection($connection)->push($job, $data, $queue); - } - - /** - * Push a new an array of jobs onto the queue. - * - * @param array $jobs - * @param mixed $data - * @param string $queue - * @param string $connection - * @return mixed - */ - public static function bulk($jobs, $data = '', $queue = null, $connection = null) - { - return static::$instance->connection($connection)->bulk($jobs, $data, $queue); - } - - /** - * Push a new job onto the queue after a delay. - * - * @param \DateTime|int $delay - * @param string $job - * @param mixed $data - * @param string $queue - * @param string $connection - * @return mixed - */ - public static function later($delay, $job, $data = '', $queue = null, $connection = null) - { - return static::$instance->connection($connection)->later($delay, $job, $data, $queue); - } - - /** - * Get a registered connection instance. - * - * @param string $name - * @return \Illuminate\Queue\QueueInterface - */ - public function getConnection($name = null) - { - return $this->manager->connection($name); - } - - /** - * Register a connection with the manager. - * - * @param array $config - * @param string $name - * @return void - */ - public function addConnection(array $config, $name = 'default') - { - $this->container['config']["queue.connections.{$name}"] = $config; - } - - /** - * Get the queue manager instance. - * - * @return \Illuminate\Queue\QueueManager - */ - public function getQueueManager() - { - return $this->manager; - } - - /** - * Pass dynamic instance methods to the manager. - * - * @param string $method - * @param array $parameters - * @return mixed - */ - public function __call($method, $parameters) - { - return call_user_func_array(array($this->manager, $method), $parameters); - } - - /** - * Dynamically pass methods to the default connection. - * - * @param string $method - * @param array $parameters - * @return mixed - */ - public static function __callStatic($method, $parameters) - { - return call_user_func_array(array(static::connection(), $method), $parameters); - } - -} http://git-wip-us.apache.org/repos/asf/airavata-php-gateway/blob/80fd786e/vendor/laravel/framework/src/Illuminate/Queue/Connectors/BeanstalkdConnector.php ---------------------------------------------------------------------- diff --git a/vendor/laravel/framework/src/Illuminate/Queue/Connectors/BeanstalkdConnector.php b/vendor/laravel/framework/src/Illuminate/Queue/Connectors/BeanstalkdConnector.php deleted file mode 100755 index 12607cd..0000000 --- a/vendor/laravel/framework/src/Illuminate/Queue/Connectors/BeanstalkdConnector.php +++ /dev/null @@ -1,24 +0,0 @@ -<?php namespace Illuminate\Queue\Connectors; - -use Illuminate\Queue\BeanstalkdQueue; -use Pheanstalk_Pheanstalk as Pheanstalk; -use Pheanstalk_PheanstalkInterface as PheanstalkInterface; - -class BeanstalkdConnector implements ConnectorInterface { - - /** - * Establish a queue connection. - * - * @param array $config - * @return \Illuminate\Queue\QueueInterface - */ - public function connect(array $config) - { - $pheanstalk = new Pheanstalk($config['host'], array_get($config, 'port', PheanstalkInterface::DEFAULT_PORT)); - - return new BeanstalkdQueue( - $pheanstalk, $config['queue'], array_get($config, 'ttr', Pheanstalk::DEFAULT_TTR) - ); - } - -} http://git-wip-us.apache.org/repos/asf/airavata-php-gateway/blob/80fd786e/vendor/laravel/framework/src/Illuminate/Queue/Connectors/ConnectorInterface.php ---------------------------------------------------------------------- diff --git a/vendor/laravel/framework/src/Illuminate/Queue/Connectors/ConnectorInterface.php b/vendor/laravel/framework/src/Illuminate/Queue/Connectors/ConnectorInterface.php deleted file mode 100755 index e952833..0000000 --- a/vendor/laravel/framework/src/Illuminate/Queue/Connectors/ConnectorInterface.php +++ /dev/null @@ -1,13 +0,0 @@ -<?php namespace Illuminate\Queue\Connectors; - -interface ConnectorInterface { - - /** - * Establish a queue connection. - * - * @param array $config - * @return \Illuminate\Queue\QueueInterface - */ - public function connect(array $config); - -} http://git-wip-us.apache.org/repos/asf/airavata-php-gateway/blob/80fd786e/vendor/laravel/framework/src/Illuminate/Queue/Connectors/IronConnector.php ---------------------------------------------------------------------- diff --git a/vendor/laravel/framework/src/Illuminate/Queue/Connectors/IronConnector.php b/vendor/laravel/framework/src/Illuminate/Queue/Connectors/IronConnector.php deleted file mode 100755 index 071c657..0000000 --- a/vendor/laravel/framework/src/Illuminate/Queue/Connectors/IronConnector.php +++ /dev/null @@ -1,59 +0,0 @@ -<?php namespace Illuminate\Queue\Connectors; - -use IronMQ; -use Illuminate\Http\Request; -use Illuminate\Queue\IronQueue; -use Illuminate\Encryption\Encrypter; - -class IronConnector implements ConnectorInterface { - - /** - * The encrypter instance. - * - * @var \Illuminate\Encryption\Encrypter - */ - protected $crypt; - - /** - * The current request instance. - * - * @var \Illuminate\Http\Request - */ - protected $request; - - /** - * Create a new Iron connector instance. - * - * @param \Illuminate\Encryption\Encrypter $crypt - * @param \Illuminate\Http\Request $request - * @return void - */ - public function __construct(Encrypter $crypt, Request $request) - { - $this->crypt = $crypt; - $this->request = $request; - } - - /** - * Establish a queue connection. - * - * @param array $config - * @return \Illuminate\Queue\QueueInterface - */ - public function connect(array $config) - { - $ironConfig = array('token' => $config['token'], 'project_id' => $config['project']); - - if (isset($config['host'])) $ironConfig['host'] = $config['host']; - - $iron = new IronMQ($ironConfig); - - if (isset($config['ssl_verifypeer'])) - { - $iron->ssl_verifypeer = $config['ssl_verifypeer']; - } - - return new IronQueue($iron, $this->request, $config['queue'], $config['encrypt']); - } - -} http://git-wip-us.apache.org/repos/asf/airavata-php-gateway/blob/80fd786e/vendor/laravel/framework/src/Illuminate/Queue/Connectors/RedisConnector.php ---------------------------------------------------------------------- diff --git a/vendor/laravel/framework/src/Illuminate/Queue/Connectors/RedisConnector.php b/vendor/laravel/framework/src/Illuminate/Queue/Connectors/RedisConnector.php deleted file mode 100644 index 59821fd..0000000 --- a/vendor/laravel/framework/src/Illuminate/Queue/Connectors/RedisConnector.php +++ /dev/null @@ -1,52 +0,0 @@ -<?php namespace Illuminate\Queue\Connectors; - -use Illuminate\Redis\Database; -use Illuminate\Queue\RedisQueue; - -class RedisConnector implements ConnectorInterface { - - /** - * The Redis database instance. - * - * @var \Illuminate\Redis\Database - */ - protected $redis; - - /** - * The connection name. - * - * @var string - */ - protected $connection; - - /** - * Create a new Redis queue connector instance. - * - * @param \Illuminate\Redis\Database $redis - * @param string|null $connection - * @return void - */ - public function __construct(Database $redis, $connection = null) - { - $this->redis = $redis; - $this->connection = $connection; - } - - /** - * Establish a queue connection. - * - * @param array $config - * @return \Illuminate\Queue\QueueInterface - */ - public function connect(array $config) - { - $queue = new RedisQueue( - $this->redis, $config['queue'], array_get($config, 'connection', $this->connection) - ); - - $queue->setExpire(array_get($config, 'expire', 60)); - - return $queue; - } - -} http://git-wip-us.apache.org/repos/asf/airavata-php-gateway/blob/80fd786e/vendor/laravel/framework/src/Illuminate/Queue/Connectors/SqsConnector.php ---------------------------------------------------------------------- diff --git a/vendor/laravel/framework/src/Illuminate/Queue/Connectors/SqsConnector.php b/vendor/laravel/framework/src/Illuminate/Queue/Connectors/SqsConnector.php deleted file mode 100755 index 86aeeca..0000000 --- a/vendor/laravel/framework/src/Illuminate/Queue/Connectors/SqsConnector.php +++ /dev/null @@ -1,21 +0,0 @@ -<?php namespace Illuminate\Queue\Connectors; - -use Aws\Sqs\SqsClient; -use Illuminate\Queue\SqsQueue; - -class SqsConnector implements ConnectorInterface { - - /** - * Establish a queue connection. - * - * @param array $config - * @return \Illuminate\Queue\QueueInterface - */ - public function connect(array $config) - { - $sqs = SqsClient::factory($config); - - return new SqsQueue($sqs, $config['queue']); - } - -} http://git-wip-us.apache.org/repos/asf/airavata-php-gateway/blob/80fd786e/vendor/laravel/framework/src/Illuminate/Queue/Connectors/SyncConnector.php ---------------------------------------------------------------------- diff --git a/vendor/laravel/framework/src/Illuminate/Queue/Connectors/SyncConnector.php b/vendor/laravel/framework/src/Illuminate/Queue/Connectors/SyncConnector.php deleted file mode 100755 index 1c3ae66..0000000 --- a/vendor/laravel/framework/src/Illuminate/Queue/Connectors/SyncConnector.php +++ /dev/null @@ -1,18 +0,0 @@ -<?php namespace Illuminate\Queue\Connectors; - -use Illuminate\Queue\SyncQueue; - -class SyncConnector implements ConnectorInterface { - - /** - * Establish a queue connection. - * - * @param array $config - * @return \Illuminate\Queue\QueueInterface - */ - public function connect(array $config) - { - return new SyncQueue; - } - -} http://git-wip-us.apache.org/repos/asf/airavata-php-gateway/blob/80fd786e/vendor/laravel/framework/src/Illuminate/Queue/Console/FailedTableCommand.php ---------------------------------------------------------------------- diff --git a/vendor/laravel/framework/src/Illuminate/Queue/Console/FailedTableCommand.php b/vendor/laravel/framework/src/Illuminate/Queue/Console/FailedTableCommand.php deleted file mode 100644 index 0b485dd..0000000 --- a/vendor/laravel/framework/src/Illuminate/Queue/Console/FailedTableCommand.php +++ /dev/null @@ -1,70 +0,0 @@ -<?php namespace Illuminate\Queue\Console; - -use Illuminate\Console\Command; -use Illuminate\Filesystem\Filesystem; - -class FailedTableCommand extends Command { - - /** - * The console command name. - * - * @var string - */ - protected $name = 'queue:failed-table'; - - /** - * The console command description. - * - * @var string - */ - protected $description = 'Create a migration for the failed queue jobs database table'; - - /** - * The filesystem instance. - * - * @var \Illuminate\Filesystem\Filesystem - */ - protected $files; - - /** - * Create a new session table command instance. - * - * @param \Illuminate\Filesystem\Filesystem $files - * @return void - */ - public function __construct(Filesystem $files) - { - parent::__construct(); - - $this->files = $files; - } - - /** - * Execute the console command. - * - * @return void - */ - public function fire() - { - $fullPath = $this->createBaseMigration(); - - $this->files->put($fullPath, $this->files->get(__DIR__.'/stubs/failed_jobs.stub')); - - $this->info('Migration created successfully!'); - } - - /** - * Create a base migration file for the table. - * - * @return string - */ - protected function createBaseMigration() - { - $name = 'create_failed_jobs_table'; - - $path = $this->laravel['path'].'/database/migrations'; - - return $this->laravel['migration.creator']->create($name, $path); - } - -} http://git-wip-us.apache.org/repos/asf/airavata-php-gateway/blob/80fd786e/vendor/laravel/framework/src/Illuminate/Queue/Console/FlushFailedCommand.php ---------------------------------------------------------------------- diff --git a/vendor/laravel/framework/src/Illuminate/Queue/Console/FlushFailedCommand.php b/vendor/laravel/framework/src/Illuminate/Queue/Console/FlushFailedCommand.php deleted file mode 100644 index 0ece99b..0000000 --- a/vendor/laravel/framework/src/Illuminate/Queue/Console/FlushFailedCommand.php +++ /dev/null @@ -1,33 +0,0 @@ -<?php namespace Illuminate\Queue\Console; - -use Illuminate\Console\Command; - -class FlushFailedCommand extends Command { - - /** - * The console command name. - * - * @var string - */ - protected $name = 'queue:flush'; - - /** - * The console command description. - * - * @var string - */ - protected $description = 'Flush all of the failed queue jobs'; - - /** - * Execute the console command. - * - * @return void - */ - public function fire() - { - $this->laravel['queue.failer']->flush(); - - $this->info('All failed jobs deleted successfully!'); - } - -} http://git-wip-us.apache.org/repos/asf/airavata-php-gateway/blob/80fd786e/vendor/laravel/framework/src/Illuminate/Queue/Console/ForgetFailedCommand.php ---------------------------------------------------------------------- diff --git a/vendor/laravel/framework/src/Illuminate/Queue/Console/ForgetFailedCommand.php b/vendor/laravel/framework/src/Illuminate/Queue/Console/ForgetFailedCommand.php deleted file mode 100644 index fef76f0..0000000 --- a/vendor/laravel/framework/src/Illuminate/Queue/Console/ForgetFailedCommand.php +++ /dev/null @@ -1,51 +0,0 @@ -<?php namespace Illuminate\Queue\Console; - -use Illuminate\Console\Command; -use Symfony\Component\Console\Input\InputArgument; - -class ForgetFailedCommand extends Command { - - /** - * The console command name. - * - * @var string - */ - protected $name = 'queue:forget'; - - /** - * The console command description. - * - * @var string - */ - protected $description = 'Delete a failed queue job'; - - /** - * Execute the console command. - * - * @return void - */ - public function fire() - { - if ($this->laravel['queue.failer']->forget($this->argument('id'))) - { - $this->info('Failed job deleted successfully!'); - } - else - { - $this->error('No failed job matches the given ID.'); - } - } - - /** - * Get the console command arguments. - * - * @return array - */ - protected function getArguments() - { - return array( - array('id', InputArgument::REQUIRED, 'The ID of the failed job'), - ); - } - -} http://git-wip-us.apache.org/repos/asf/airavata-php-gateway/blob/80fd786e/vendor/laravel/framework/src/Illuminate/Queue/Console/ListFailedCommand.php ---------------------------------------------------------------------- diff --git a/vendor/laravel/framework/src/Illuminate/Queue/Console/ListFailedCommand.php b/vendor/laravel/framework/src/Illuminate/Queue/Console/ListFailedCommand.php deleted file mode 100644 index 03bc411..0000000 --- a/vendor/laravel/framework/src/Illuminate/Queue/Console/ListFailedCommand.php +++ /dev/null @@ -1,62 +0,0 @@ -<?php namespace Illuminate\Queue\Console; - -use Illuminate\Console\Command; - -class ListFailedCommand extends Command { - - /** - * The console command name. - * - * @var string - */ - protected $name = 'queue:failed'; - - /** - * The console command description. - * - * @var string - */ - protected $description = 'List all of the failed queue jobs'; - - /** - * Execute the console command. - * - * @return void - */ - public function fire() - { - $rows = array(); - - foreach ($this->laravel['queue.failer']->all() as $failed) - { - $rows[] = $this->parseFailedJob((array) $failed); - } - - if (count($rows) == 0) - { - return $this->info('No failed jobs!'); - } - - $table = $this->getHelperSet()->get('table'); - - $table->setHeaders(array('ID', 'Connection', 'Queue', 'Class', 'Failed At')) - ->setRows($rows) - ->render($this->output); - } - - /** - * Parse the failed job row. - * - * @param array $failed - * @return array - */ - protected function parseFailedJob(array $failed) - { - $row = array_values(array_except($failed, array('payload'))); - - array_splice($row, 3, 0, array_get(json_decode($failed['payload'], true), 'job')); - - return $row; - } - -} http://git-wip-us.apache.org/repos/asf/airavata-php-gateway/blob/80fd786e/vendor/laravel/framework/src/Illuminate/Queue/Console/ListenCommand.php ---------------------------------------------------------------------- diff --git a/vendor/laravel/framework/src/Illuminate/Queue/Console/ListenCommand.php b/vendor/laravel/framework/src/Illuminate/Queue/Console/ListenCommand.php deleted file mode 100755 index f138b3c..0000000 --- a/vendor/laravel/framework/src/Illuminate/Queue/Console/ListenCommand.php +++ /dev/null @@ -1,145 +0,0 @@ -<?php namespace Illuminate\Queue\Console; - -use Illuminate\Queue\Listener; -use Illuminate\Console\Command; -use Symfony\Component\Console\Input\InputOption; -use Symfony\Component\Console\Input\InputArgument; - -class ListenCommand extends Command { - - /** - * The console command name. - * - * @var string - */ - protected $name = 'queue:listen'; - - /** - * The console command description. - * - * @var string - */ - protected $description = 'Listen to a given queue'; - - /** - * The queue listener instance. - * - * @var \Illuminate\Queue\Listener - */ - protected $listener; - - /** - * Create a new queue listen command. - * - * @param \Illuminate\Queue\Listener $listener - * @return void - */ - public function __construct(Listener $listener) - { - parent::__construct(); - - $this->listener = $listener; - } - - /** - * Execute the console command. - * - * @return void - */ - public function fire() - { - $this->setListenerOptions(); - - $delay = $this->input->getOption('delay'); - - // The memory limit is the amount of memory we will allow the script to occupy - // before killing it and letting a process manager restart it for us, which - // is to protect us against any memory leaks that will be in the scripts. - $memory = $this->input->getOption('memory'); - - $connection = $this->input->getArgument('connection'); - - $timeout = $this->input->getOption('timeout'); - - // We need to get the right queue for the connection which is set in the queue - // configuration file for the application. We will pull it based on the set - // connection being run for the queue operation currently being executed. - $queue = $this->getQueue($connection); - - $this->listener->listen( - $connection, $queue, $delay, $memory, $timeout - ); - } - - /** - * Get the name of the queue connection to listen on. - * - * @param string $connection - * @return string - */ - protected function getQueue($connection) - { - if (is_null($connection)) - { - $connection = $this->laravel['config']['queue.default']; - } - - $queue = $this->laravel['config']->get("queue.connections.{$connection}.queue", 'default'); - - return $this->input->getOption('queue') ?: $queue; - } - - /** - * Set the options on the queue listener. - * - * @return void - */ - protected function setListenerOptions() - { - $this->listener->setEnvironment($this->laravel->environment()); - - $this->listener->setSleep($this->option('sleep')); - - $this->listener->setMaxTries($this->option('tries')); - - $this->listener->setOutputHandler(function($type, $line) - { - $this->output->write($line); - }); - } - - /** - * Get the console command arguments. - * - * @return array - */ - protected function getArguments() - { - return array( - array('connection', InputArgument::OPTIONAL, 'The name of connection'), - ); - } - - /** - * Get the console command options. - * - * @return array - */ - protected function getOptions() - { - return array( - array('queue', null, InputOption::VALUE_OPTIONAL, 'The queue to listen on', null), - - array('delay', null, InputOption::VALUE_OPTIONAL, 'Amount of time to delay failed jobs', 0), - - array('memory', null, InputOption::VALUE_OPTIONAL, 'The memory limit in megabytes', 128), - - array('timeout', null, InputOption::VALUE_OPTIONAL, 'Seconds a job may run before timing out', 60), - - array('sleep', null, InputOption::VALUE_OPTIONAL, 'Seconds to wait before checking queue for jobs', 3), - - array('tries', null, InputOption::VALUE_OPTIONAL, 'Number of times to attempt a job before logging it failed', 0), - ); - } - -} http://git-wip-us.apache.org/repos/asf/airavata-php-gateway/blob/80fd786e/vendor/laravel/framework/src/Illuminate/Queue/Console/RestartCommand.php ---------------------------------------------------------------------- diff --git a/vendor/laravel/framework/src/Illuminate/Queue/Console/RestartCommand.php b/vendor/laravel/framework/src/Illuminate/Queue/Console/RestartCommand.php deleted file mode 100644 index de02cd7..0000000 --- a/vendor/laravel/framework/src/Illuminate/Queue/Console/RestartCommand.php +++ /dev/null @@ -1,33 +0,0 @@ -<?php namespace Illuminate\Queue\Console; - -use Illuminate\Console\Command; - -class RestartCommand extends Command { - - /** - * The console command name. - * - * @var string - */ - protected $name = 'queue:restart'; - - /** - * The console command description. - * - * @var string - */ - protected $description = "Restart queue worker daemons after their current job."; - - /** - * Execute the console command. - * - * @return void - */ - public function fire() - { - $this->laravel['cache']->forever('illuminate:queue:restart', time()); - - $this->info('Broadcasting queue restart signal.'); - } - -} http://git-wip-us.apache.org/repos/asf/airavata-php-gateway/blob/80fd786e/vendor/laravel/framework/src/Illuminate/Queue/Console/RetryCommand.php ---------------------------------------------------------------------- diff --git a/vendor/laravel/framework/src/Illuminate/Queue/Console/RetryCommand.php b/vendor/laravel/framework/src/Illuminate/Queue/Console/RetryCommand.php deleted file mode 100644 index 454b56d..0000000 --- a/vendor/laravel/framework/src/Illuminate/Queue/Console/RetryCommand.php +++ /dev/null @@ -1,74 +0,0 @@ -<?php namespace Illuminate\Queue\Console; - -use Illuminate\Console\Command; -use Symfony\Component\Console\Input\InputArgument; - -class RetryCommand extends Command { - - /** - * The console command name. - * - * @var string - */ - protected $name = 'queue:retry'; - - /** - * The console command description. - * - * @var string - */ - protected $description = 'Retry a failed queue job'; - - /** - * Execute the console command. - * - * @return void - */ - public function fire() - { - $failed = $this->laravel['queue.failer']->find($this->argument('id')); - - if ( ! is_null($failed)) - { - $failed->payload = $this->resetAttempts($failed->payload); - - $this->laravel['queue']->connection($failed->connection)->pushRaw($failed->payload, $failed->queue); - - $this->laravel['queue.failer']->forget($failed->id); - - $this->info('The failed job has been pushed back onto the queue!'); - } - else - { - $this->error('No failed job matches the given ID.'); - } - } - - /** - * Reset the payload attempts. - * - * @param string $payload - * @return string - */ - protected function resetAttempts($payload) - { - $payload = json_decode($payload, true); - - if (isset($payload['attempts'])) $payload['attempts'] = 0; - - return json_encode($payload); - } - - /** - * Get the console command arguments. - * - * @return array - */ - protected function getArguments() - { - return array( - array('id', InputArgument::REQUIRED, 'The ID of the failed job'), - ); - } - -} http://git-wip-us.apache.org/repos/asf/airavata-php-gateway/blob/80fd786e/vendor/laravel/framework/src/Illuminate/Queue/Console/SubscribeCommand.php ---------------------------------------------------------------------- diff --git a/vendor/laravel/framework/src/Illuminate/Queue/Console/SubscribeCommand.php b/vendor/laravel/framework/src/Illuminate/Queue/Console/SubscribeCommand.php deleted file mode 100755 index 89c4209..0000000 --- a/vendor/laravel/framework/src/Illuminate/Queue/Console/SubscribeCommand.php +++ /dev/null @@ -1,153 +0,0 @@ -<?php namespace Illuminate\Queue\Console; - -use RuntimeException; -use Illuminate\Queue\IronQueue; -use Illuminate\Console\Command; -use Symfony\Component\Console\Input\InputOption; -use Symfony\Component\Console\Input\InputArgument; - -class SubscribeCommand extends Command { - - /** - * The console command name. - * - * @var string - */ - protected $name = 'queue:subscribe'; - - /** - * The console command description. - * - * @var string - */ - protected $description = 'Subscribe a URL to an Iron.io push queue'; - - /** - * The queue meta information from Iron.io. - * - * @var object - */ - protected $meta; - - /** - * Execute the console command. - * - * @return void - * - * @throws \RuntimeException - */ - public function fire() - { - $iron = $this->laravel['queue']->connection(); - - if ( ! $iron instanceof IronQueue) - { - throw new RuntimeException("Iron.io based queue must be default."); - } - - $iron->getIron()->updateQueue($this->argument('queue'), $this->getQueueOptions()); - - $this->line('<info>Queue subscriber added:</info> <comment>'.$this->argument('url').'</comment>'); - } - - /** - * Get the queue options. - * - * @return array - */ - protected function getQueueOptions() - { - return array( - 'push_type' => $this->getPushType(), 'subscribers' => $this->getSubscriberList() - ); - } - - /** - * Get the push type for the queue. - * - * @return string - */ - protected function getPushType() - { - if ($this->option('type')) return $this->option('type'); - - try - { - return $this->getQueue()->push_type; - } - catch (\Exception $e) - { - return 'multicast'; - } - } - - /** - * Get the current subscribers for the queue. - * - * @return array - */ - protected function getSubscriberList() - { - $subscribers = $this->getCurrentSubscribers(); - - $subscribers[] = array('url' => $this->argument('url')); - - return $subscribers; - } - - /** - * Get the current subscriber list. - * - * @return array - */ - protected function getCurrentSubscribers() - { - try - { - return $this->getQueue()->subscribers; - } - catch (\Exception $e) - { - return array(); - } - } - - /** - * Get the queue information from Iron.io. - * - * @return object - */ - protected function getQueue() - { - if (isset($this->meta)) return $this->meta; - - return $this->meta = $this->laravel['queue']->getIron()->getQueue($this->argument('queue')); - } - - /** - * Get the console command arguments. - * - * @return array - */ - protected function getArguments() - { - return array( - array('queue', InputArgument::REQUIRED, 'The name of Iron.io queue.'), - - array('url', InputArgument::REQUIRED, 'The URL to be subscribed.'), - ); - } - - /** - * Get the console command options. - * - * @return array - */ - protected function getOptions() - { - return array( - array('type', null, InputOption::VALUE_OPTIONAL, 'The push type for the queue.'), - ); - } - -} http://git-wip-us.apache.org/repos/asf/airavata-php-gateway/blob/80fd786e/vendor/laravel/framework/src/Illuminate/Queue/Console/WorkCommand.php ---------------------------------------------------------------------- diff --git a/vendor/laravel/framework/src/Illuminate/Queue/Console/WorkCommand.php b/vendor/laravel/framework/src/Illuminate/Queue/Console/WorkCommand.php deleted file mode 100755 index 859cc63..0000000 --- a/vendor/laravel/framework/src/Illuminate/Queue/Console/WorkCommand.php +++ /dev/null @@ -1,175 +0,0 @@ -<?php namespace Illuminate\Queue\Console; - -use Illuminate\Queue\Worker; -use Illuminate\Queue\Jobs\Job; -use Illuminate\Console\Command; -use Symfony\Component\Console\Input\InputOption; -use Symfony\Component\Console\Input\InputArgument; - -class WorkCommand extends Command { - - /** - * The console command name. - * - * @var string - */ - protected $name = 'queue:work'; - - /** - * The console command description. - * - * @var string - */ - protected $description = 'Process the next job on a queue'; - - /** - * The queue worker instance. - * - * @var \Illuminate\Queue\Worker - */ - protected $worker; - - /** - * Create a new queue listen command. - * - * @param \Illuminate\Queue\Worker $worker - * @return void - */ - public function __construct(Worker $worker) - { - parent::__construct(); - - $this->worker = $worker; - } - - /** - * Execute the console command. - * - * @return void - */ - public function fire() - { - if ($this->downForMaintenance() && ! $this->option('daemon')) return; - - $queue = $this->option('queue'); - - $delay = $this->option('delay'); - - // The memory limit is the amount of memory we will allow the script to occupy - // before killing it and letting a process manager restart it for us, which - // is to protect us against any memory leaks that will be in the scripts. - $memory = $this->option('memory'); - - $connection = $this->argument('connection'); - - $response = $this->runWorker( - $connection, $queue, $delay, $memory, $this->option('daemon') - ); - - // If a job was fired by the worker, we'll write the output out to the console - // so that the developer can watch live while the queue runs in the console - // window, which will also of get logged if stdout is logged out to disk. - if ( ! is_null($response['job'])) - { - $this->writeOutput($response['job'], $response['failed']); - } - } - - /** - * Run the worker instance. - * - * @param string $connection - * @param string $queue - * @param int $delay - * @param int $memory - * @param bool $daemon - * @return array - */ - protected function runWorker($connection, $queue, $delay, $memory, $daemon = false) - { - if ($daemon) - { - $this->worker->setCache($this->laravel['cache']->driver()); - - $this->worker->setDaemonExceptionHandler($this->laravel['exception']); - - return $this->worker->daemon( - $connection, $queue, $delay, $memory, - $this->option('sleep'), $this->option('tries') - ); - } - - return $this->worker->pop( - $connection, $queue, $delay, - $this->option('sleep'), $this->option('tries') - ); - } - - /** - * Write the status output for the queue worker. - * - * @param \Illuminate\Queue\Jobs\Job $job - * @param bool $failed - * @return void - */ - protected function writeOutput(Job $job, $failed) - { - if ($failed) - { - $this->output->writeln('<error>Failed:</error> '.$job->getName()); - } - else - { - $this->output->writeln('<info>Processed:</info> '.$job->getName()); - } - } - - /** - * Determine if the worker should run in maintenance mode. - * - * @return bool - */ - protected function downForMaintenance() - { - if ($this->option('force')) return false; - - return $this->laravel->isDownForMaintenance(); - } - - /** - * Get the console command arguments. - * - * @return array - */ - protected function getArguments() - { - return array( - array('connection', InputArgument::OPTIONAL, 'The name of connection', null), - ); - } - - /** - * Get the console command options. - * - * @return array - */ - protected function getOptions() - { - return array( - array('queue', null, InputOption::VALUE_OPTIONAL, 'The queue to listen on'), - - array('daemon', null, InputOption::VALUE_NONE, 'Run the worker in daemon mode'), - - array('delay', null, InputOption::VALUE_OPTIONAL, 'Amount of time to delay failed jobs', 0), - - array('force', null, InputOption::VALUE_NONE, 'Force the worker to run even in maintenance mode'), - - array('memory', null, InputOption::VALUE_OPTIONAL, 'The memory limit in megabytes', 128), - - array('sleep', null, InputOption::VALUE_OPTIONAL, 'Number of seconds to sleep when no job is available', 3), - - array('tries', null, InputOption::VALUE_OPTIONAL, 'Number of times to attempt a job before logging it failed', 0), - ); - } - -} http://git-wip-us.apache.org/repos/asf/airavata-php-gateway/blob/80fd786e/vendor/laravel/framework/src/Illuminate/Queue/Console/stubs/failed_jobs.stub ---------------------------------------------------------------------- diff --git a/vendor/laravel/framework/src/Illuminate/Queue/Console/stubs/failed_jobs.stub b/vendor/laravel/framework/src/Illuminate/Queue/Console/stubs/failed_jobs.stub deleted file mode 100644 index 61efc17..0000000 --- a/vendor/laravel/framework/src/Illuminate/Queue/Console/stubs/failed_jobs.stub +++ /dev/null @@ -1,35 +0,0 @@ -<?php - -use Illuminate\Database\Schema\Blueprint; -use Illuminate\Database\Migrations\Migration; - -class CreateFailedJobsTable extends Migration { - - /** - * Run the migrations. - * - * @return void - */ - public function up() - { - Schema::create('failed_jobs', function(Blueprint $table) - { - $table->increments('id'); - $table->text('connection'); - $table->text('queue'); - $table->text('payload'); - $table->timestamp('failed_at'); - }); - } - - /** - * Reverse the migrations. - * - * @return void - */ - public function down() - { - Schema::drop('failed_jobs'); - } - -} http://git-wip-us.apache.org/repos/asf/airavata-php-gateway/blob/80fd786e/vendor/laravel/framework/src/Illuminate/Queue/FailConsoleServiceProvider.php ---------------------------------------------------------------------- diff --git a/vendor/laravel/framework/src/Illuminate/Queue/FailConsoleServiceProvider.php b/vendor/laravel/framework/src/Illuminate/Queue/FailConsoleServiceProvider.php deleted file mode 100644 index 6551877..0000000 --- a/vendor/laravel/framework/src/Illuminate/Queue/FailConsoleServiceProvider.php +++ /dev/null @@ -1,69 +0,0 @@ -<?php namespace Illuminate\Queue; - -use Illuminate\Support\ServiceProvider; -use Illuminate\Queue\Console\RetryCommand; -use Illuminate\Queue\Console\ListFailedCommand; -use Illuminate\Queue\Console\FlushFailedCommand; -use Illuminate\Queue\Console\FailedTableCommand; -use Illuminate\Queue\Console\ForgetFailedCommand; - -class FailConsoleServiceProvider extends ServiceProvider { - - /** - * Indicates if loading of the provider is deferred. - * - * @var bool - */ - protected $defer = true; - - /** - * Register the service provider. - * - * @return void - */ - public function register() - { - $this->app->bindShared('command.queue.failed', function() - { - return new ListFailedCommand; - }); - - $this->app->bindShared('command.queue.retry', function() - { - return new RetryCommand; - }); - - $this->app->bindShared('command.queue.forget', function() - { - return new ForgetFailedCommand; - }); - - $this->app->bindShared('command.queue.flush', function() - { - return new FlushFailedCommand; - }); - - $this->app->bindShared('command.queue.failed-table', function($app) - { - return new FailedTableCommand($app['files']); - }); - - $this->commands( - 'command.queue.failed', 'command.queue.retry', 'command.queue.forget', - 'command.queue.flush', 'command.queue.failed-table' - ); - } - - /** - * Get the services provided by the provider. - * - * @return array - */ - public function provides() - { - return array( - 'command.queue.failed', 'command.queue.retry', 'command.queue.forget', 'command.queue.flush', 'command.queue.failed-table', - ); - } - -} http://git-wip-us.apache.org/repos/asf/airavata-php-gateway/blob/80fd786e/vendor/laravel/framework/src/Illuminate/Queue/Failed/DatabaseFailedJobProvider.php ---------------------------------------------------------------------- diff --git a/vendor/laravel/framework/src/Illuminate/Queue/Failed/DatabaseFailedJobProvider.php b/vendor/laravel/framework/src/Illuminate/Queue/Failed/DatabaseFailedJobProvider.php deleted file mode 100644 index 1fbf6f1..0000000 --- a/vendor/laravel/framework/src/Illuminate/Queue/Failed/DatabaseFailedJobProvider.php +++ /dev/null @@ -1,111 +0,0 @@ -<?php namespace Illuminate\Queue\Failed; - -use Carbon\Carbon; -use Illuminate\Database\ConnectionResolverInterface; - -class DatabaseFailedJobProvider implements FailedJobProviderInterface { - - /** - * The connection resolver implementation. - * - * @var \Illuminate\Database\ConnectionResolverInterface - */ - protected $resolver; - - /** - * The database connection name. - * - * @var string - */ - protected $database; - - /** - * The database table. - * - * @var string - */ - protected $table; - - /** - * Create a new database failed job provider. - * - * @param \Illuminate\Database\ConnectionResolverInterface $resolver - * @param string $database - * @param string $table - * @return void - */ - public function __construct(ConnectionResolverInterface $resolver, $database, $table) - { - $this->table = $table; - $this->resolver = $resolver; - $this->database = $database; - } - - /** - * Log a failed job into storage. - * - * @param string $connection - * @param string $queue - * @param string $payload - * @return void - */ - public function log($connection, $queue, $payload) - { - $failed_at = Carbon::now(); - - $this->getTable()->insert(compact('connection', 'queue', 'payload', 'failed_at')); - } - - /** - * Get a list of all of the failed jobs. - * - * @return array - */ - public function all() - { - return $this->getTable()->orderBy('id', 'desc')->get(); - } - - /** - * Get a single failed job. - * - * @param mixed $id - * @return array - */ - public function find($id) - { - return $this->getTable()->find($id); - } - - /** - * Delete a single failed job from storage. - * - * @param mixed $id - * @return bool - */ - public function forget($id) - { - return $this->getTable()->where('id', $id)->delete() > 0; - } - - /** - * Flush all of the failed jobs from storage. - * - * @return void - */ - public function flush() - { - $this->getTable()->delete(); - } - - /** - * Get a new query builder instance for the table. - * - * @return \Illuminate\Database\Query\Builder - */ - protected function getTable() - { - return $this->resolver->connection($this->database)->table($this->table); - } - -} http://git-wip-us.apache.org/repos/asf/airavata-php-gateway/blob/80fd786e/vendor/laravel/framework/src/Illuminate/Queue/Failed/FailedJobProviderInterface.php ---------------------------------------------------------------------- diff --git a/vendor/laravel/framework/src/Illuminate/Queue/Failed/FailedJobProviderInterface.php b/vendor/laravel/framework/src/Illuminate/Queue/Failed/FailedJobProviderInterface.php deleted file mode 100644 index 7db652e..0000000 --- a/vendor/laravel/framework/src/Illuminate/Queue/Failed/FailedJobProviderInterface.php +++ /dev/null @@ -1,45 +0,0 @@ -<?php namespace Illuminate\Queue\Failed; - -interface FailedJobProviderInterface { - - /** - * Log a failed job into storage. - * - * @param string $connection - * @param string $queue - * @param string $payload - * @return void - */ - public function log($connection, $queue, $payload); - - /** - * Get a list of all of the failed jobs. - * - * @return array - */ - public function all(); - - /** - * Get a single failed job. - * - * @param mixed $id - * @return array - */ - public function find($id); - - /** - * Delete a single failed job from storage. - * - * @param mixed $id - * @return bool - */ - public function forget($id); - - /** - * Flush all of the failed jobs from storage. - * - * @return void - */ - public function flush(); - -} http://git-wip-us.apache.org/repos/asf/airavata-php-gateway/blob/80fd786e/vendor/laravel/framework/src/Illuminate/Queue/IlluminateQueueClosure.php ---------------------------------------------------------------------- diff --git a/vendor/laravel/framework/src/Illuminate/Queue/IlluminateQueueClosure.php b/vendor/laravel/framework/src/Illuminate/Queue/IlluminateQueueClosure.php deleted file mode 100755 index 21056c6..0000000 --- a/vendor/laravel/framework/src/Illuminate/Queue/IlluminateQueueClosure.php +++ /dev/null @@ -1,39 +0,0 @@ -<?php - -use Illuminate\Encryption\Encrypter; - -class IlluminateQueueClosure { - - /** - * The encrypter instance. - * - * @var \Illuminate\Encryption\Encrypter $crypt - */ - protected $crypt; - - /** - * Create a new queued Closure job. - * - * @param \Illuminate\Encryption\Encrypter $crypt - * @return void - */ - public function __construct(Encrypter $crypt) - { - $this->crypt = $crypt; - } - - /** - * Fire the Closure based queue job. - * - * @param \Illuminate\Queue\Jobs\Job $job - * @param array $data - * @return void - */ - public function fire($job, $data) - { - $closure = unserialize($this->crypt->decrypt($data['closure'])); - - $closure($job); - } - -} http://git-wip-us.apache.org/repos/asf/airavata-php-gateway/blob/80fd786e/vendor/laravel/framework/src/Illuminate/Queue/IronQueue.php ---------------------------------------------------------------------- diff --git a/vendor/laravel/framework/src/Illuminate/Queue/IronQueue.php b/vendor/laravel/framework/src/Illuminate/Queue/IronQueue.php deleted file mode 100755 index 1c05b3a..0000000 --- a/vendor/laravel/framework/src/Illuminate/Queue/IronQueue.php +++ /dev/null @@ -1,258 +0,0 @@ -<?php namespace Illuminate\Queue; - -use IronMQ; -use Illuminate\Http\Request; -use Illuminate\Http\Response; -use Illuminate\Queue\Jobs\IronJob; - -class IronQueue extends Queue implements QueueInterface { - - /** - * The IronMQ instance. - * - * @var IronMQ - */ - protected $iron; - - /** - * The current request instance. - * - * @var \Illuminate\Http\Request - */ - protected $request; - - /** - * The name of the default tube. - * - * @var string - */ - protected $default; - - /** - * Indicates if the messages should be encrypted. - * - * @var bool - */ - protected $shouldEncrypt; - - /** - * Create a new IronMQ queue instance. - * - * @param \IronMQ $iron - * @param \Illuminate\Http\Request $request - * @param string $default - * @param bool $shouldEncrypt - * @return void - */ - public function __construct(IronMQ $iron, Request $request, $default, $shouldEncrypt = false) - { - $this->iron = $iron; - $this->request = $request; - $this->default = $default; - $this->shouldEncrypt = $shouldEncrypt; - } - - /** - * Push a new job onto the queue. - * - * @param string $job - * @param mixed $data - * @param string $queue - * @return mixed - */ - public function push($job, $data = '', $queue = null) - { - return $this->pushRaw($this->createPayload($job, $data, $queue), $queue); - } - - /** - * Push a raw payload onto the queue. - * - * @param string $payload - * @param string $queue - * @param array $options - * @return mixed - */ - public function pushRaw($payload, $queue = null, array $options = array()) - { - if ($this->shouldEncrypt) $payload = $this->crypt->encrypt($payload); - - return $this->iron->postMessage($this->getQueue($queue), $payload, $options)->id; - } - - /** - * Push a raw payload onto the queue after encrypting the payload. - * - * @param string $payload - * @param string $queue - * @param int $delay - * @return mixed - */ - public function recreate($payload, $queue = null, $delay) - { - $options = array('delay' => $this->getSeconds($delay)); - - return $this->pushRaw($payload, $queue, $options); - } - - /** - * Push a new job onto the queue after a delay. - * - * @param \DateTime|int $delay - * @param string $job - * @param mixed $data - * @param string $queue - * @return mixed - */ - public function later($delay, $job, $data = '', $queue = null) - { - $delay = $this->getSeconds($delay); - - $payload = $this->createPayload($job, $data, $queue); - - return $this->pushRaw($payload, $queue, compact('delay')); - } - - /** - * Pop the next job off of the queue. - * - * @param string $queue - * @return \Illuminate\Queue\Jobs\Job|null - */ - public function pop($queue = null) - { - $queue = $this->getQueue($queue); - - $job = $this->iron->getMessage($queue); - - // If we were able to pop a message off of the queue, we will need to decrypt - // the message body, as all Iron.io messages are encrypted, since the push - // queues will be a security hazard to unsuspecting developers using it. - if ( ! is_null($job)) - { - $job->body = $this->parseJobBody($job->body); - - return new IronJob($this->container, $this, $job); - } - } - - /** - * Delete a message from the Iron queue. - * - * @param string $queue - * @param string $id - * @return void - */ - public function deleteMessage($queue, $id) - { - $this->iron->deleteMessage($queue, $id); - } - - /** - * Marshal a push queue request and fire the job. - * - * @return \Illuminate\Http\Response - */ - public function marshal() - { - $this->createPushedIronJob($this->marshalPushedJob())->fire(); - - return new Response('OK'); - } - - /** - * Marshal out the pushed job and payload. - * - * @return object - */ - protected function marshalPushedJob() - { - $r = $this->request; - - $body = $this->parseJobBody($r->getContent()); - - return (object) array( - 'id' => $r->header('iron-message-id'), 'body' => $body, 'pushed' => true, - ); - } - - /** - * Create a new IronJob for a pushed job. - * - * @param object $job - * @return \Illuminate\Queue\Jobs\IronJob - */ - protected function createPushedIronJob($job) - { - return new IronJob($this->container, $this, $job, true); - } - - /** - * Create a payload string from the given job and data. - * - * @param string $job - * @param mixed $data - * @param string $queue - * @return string - */ - protected function createPayload($job, $data = '', $queue = null) - { - $payload = $this->setMeta(parent::createPayload($job, $data), 'attempts', 1); - - return $this->setMeta($payload, 'queue', $this->getQueue($queue)); - } - - /** - * Parse the job body for firing. - * - * @param string $body - * @return string - */ - protected function parseJobBody($body) - { - return $this->shouldEncrypt ? $this->crypt->decrypt($body) : $body; - } - - /** - * Get the queue or return the default. - * - * @param string|null $queue - * @return string - */ - public function getQueue($queue) - { - return $queue ?: $this->default; - } - - /** - * Get the underlying IronMQ instance. - * - * @return \IronMQ - */ - public function getIron() - { - return $this->iron; - } - - /** - * Get the request instance. - * - * @return \Symfony\Component\HttpFoundation\Request - */ - public function getRequest() - { - return $this->request; - } - - /** - * Set the request instance. - * - * @param \Symfony\Component\HttpFoundation\Request $request - * @return void - */ - public function setRequest(Request $request) - { - $this->request = $request; - } - -} http://git-wip-us.apache.org/repos/asf/airavata-php-gateway/blob/80fd786e/vendor/laravel/framework/src/Illuminate/Queue/Jobs/BeanstalkdJob.php ---------------------------------------------------------------------- diff --git a/vendor/laravel/framework/src/Illuminate/Queue/Jobs/BeanstalkdJob.php b/vendor/laravel/framework/src/Illuminate/Queue/Jobs/BeanstalkdJob.php deleted file mode 100755 index 2ae99dc..0000000 --- a/vendor/laravel/framework/src/Illuminate/Queue/Jobs/BeanstalkdJob.php +++ /dev/null @@ -1,150 +0,0 @@ -<?php namespace Illuminate\Queue\Jobs; - -use Pheanstalk_Job; -use Illuminate\Container\Container; -use Pheanstalk_Pheanstalk as Pheanstalk; - -class BeanstalkdJob extends Job { - - /** - * The Pheanstalk instance. - * - * @var \Pheanstalk_Pheanstalk - */ - protected $pheanstalk; - - /** - * The Pheanstalk job instance. - * - * @var \Pheanstalk_Job - */ - protected $job; - - /** - * Create a new job instance. - * - * @param \Illuminate\Container\Container $container - * @param \Pheanstalk_Pheanstalk $pheanstalk - * @param \Pheanstalk_Job $job - * @param string $queue - * @return void - */ - public function __construct(Container $container, - Pheanstalk $pheanstalk, - Pheanstalk_Job $job, - $queue) - { - $this->job = $job; - $this->queue = $queue; - $this->container = $container; - $this->pheanstalk = $pheanstalk; - } - - /** - * Fire the job. - * - * @return void - */ - public function fire() - { - $this->resolveAndFire(json_decode($this->getRawBody(), true)); - } - - /** - * Get the raw body string for the job. - * - * @return string - */ - public function getRawBody() - { - return $this->job->getData(); - } - - /** - * Delete the job from the queue. - * - * @return void - */ - public function delete() - { - parent::delete(); - - $this->pheanstalk->delete($this->job); - } - - /** - * Release the job back into the queue. - * - * @param int $delay - * @return void - */ - public function release($delay = 0) - { - $priority = Pheanstalk::DEFAULT_PRIORITY; - - $this->pheanstalk->release($this->job, $priority, $delay); - } - - /** - * Bury the job in the queue. - * - * @return void - */ - public function bury() - { - $this->pheanstalk->bury($this->job); - } - - /** - * Get the number of times the job has been attempted. - * - * @return int - */ - public function attempts() - { - $stats = $this->pheanstalk->statsJob($this->job); - - return (int) $stats->reserves; - } - - /** - * Get the job identifier. - * - * @return string - */ - public function getJobId() - { - return $this->job->getId(); - } - - /** - * Get the IoC container instance. - * - * @return \Illuminate\Container\Container - */ - public function getContainer() - { - return $this->container; - } - - /** - * Get the underlying Pheanstalk instance. - * - * @return \Pheanstalk_Pheanstalk - */ - public function getPheanstalk() - { - return $this->pheanstalk; - } - - /** - * Get the underlying Pheanstalk job. - * - * @return \Pheanstalk_Job - */ - public function getPheanstalkJob() - { - return $this->job; - } - -} http://git-wip-us.apache.org/repos/asf/airavata-php-gateway/blob/80fd786e/vendor/laravel/framework/src/Illuminate/Queue/Jobs/IronJob.php ---------------------------------------------------------------------- diff --git a/vendor/laravel/framework/src/Illuminate/Queue/Jobs/IronJob.php b/vendor/laravel/framework/src/Illuminate/Queue/Jobs/IronJob.php deleted file mode 100755 index 2265768..0000000 --- a/vendor/laravel/framework/src/Illuminate/Queue/Jobs/IronJob.php +++ /dev/null @@ -1,171 +0,0 @@ -<?php namespace Illuminate\Queue\Jobs; - -use Illuminate\Queue\IronQueue; -use Illuminate\Container\Container; - -class IronJob extends Job { - - /** - * The Iron queue instance. - * - * @var \Illuminate\Queue\IronQueue - */ - protected $iron; - - /** - * The IronMQ message instance. - * - * @var object - */ - protected $job; - - /** - * Indicates if the message was a push message. - * - * @var bool - */ - protected $pushed = false; - - /** - * Create a new job instance. - * - * @param \Illuminate\Container\Container $container - * @param \Illuminate\Queue\IronQueue $iron - * @param object $job - * @param bool $pushed - * @return void - */ - public function __construct(Container $container, - IronQueue $iron, - $job, - $pushed = false) - { - $this->job = $job; - $this->iron = $iron; - $this->pushed = $pushed; - $this->container = $container; - } - - /** - * Fire the job. - * - * @return void - */ - public function fire() - { - $this->resolveAndFire(json_decode($this->getRawBody(), true)); - } - - /** - * Get the raw body string for the job. - * - * @return string - */ - public function getRawBody() - { - return $this->job->body; - } - - /** - * Delete the job from the queue. - * - * @return void - */ - public function delete() - { - parent::delete(); - - if (isset($this->job->pushed)) return; - - $this->iron->deleteMessage($this->getQueue(), $this->job->id); - } - - /** - * Release the job back into the queue. - * - * @param int $delay - * @return void - */ - public function release($delay = 0) - { - if ( ! $this->pushed) $this->delete(); - - $this->recreateJob($delay); - } - - /** - * Release a pushed job back onto the queue. - * - * @param int $delay - * @return void - */ - protected function recreateJob($delay) - { - $payload = json_decode($this->job->body, true); - - array_set($payload, 'attempts', array_get($payload, 'attempts', 1) + 1); - - $this->iron->recreate(json_encode($payload), $this->getQueue(), $delay); - } - - /** - * Get the number of times the job has been attempted. - * - * @return int - */ - public function attempts() - { - return array_get(json_decode($this->job->body, true), 'attempts', 1); - } - - /** - * Get the job identifier. - * - * @return string - */ - public function getJobId() - { - return $this->job->id; - } - - /** - * Get the IoC container instance. - * - * @return \Illuminate\Container\Container - */ - public function getContainer() - { - return $this->container; - } - - /** - * Get the underlying Iron queue instance. - * - * @return \Illuminate\Queue\IronQueue - */ - public function getIron() - { - return $this->iron; - } - - /** - * Get the underlying IronMQ job. - * - * @return array - */ - public function getIronJob() - { - return $this->job; - } - - /** - * Get the name of the queue the job belongs to. - * - * @return string - */ - public function getQueue() - { - return array_get(json_decode($this->job->body, true), 'queue'); - } - -} http://git-wip-us.apache.org/repos/asf/airavata-php-gateway/blob/80fd786e/vendor/laravel/framework/src/Illuminate/Queue/Jobs/Job.php ---------------------------------------------------------------------- diff --git a/vendor/laravel/framework/src/Illuminate/Queue/Jobs/Job.php b/vendor/laravel/framework/src/Illuminate/Queue/Jobs/Job.php deleted file mode 100755 index 89bde25..0000000 --- a/vendor/laravel/framework/src/Illuminate/Queue/Jobs/Job.php +++ /dev/null @@ -1,179 +0,0 @@ -<?php namespace Illuminate\Queue\Jobs; - -use DateTime; - -abstract class Job { - - /** - * The job handler instance. - * - * @var mixed - */ - protected $instance; - - /** - * The IoC container instance. - * - * @var \Illuminate\Container\Container - */ - protected $container; - - /** - * The name of the queue the job belongs to. - * - * @var string - */ - protected $queue; - - /** - * Indicates if the job has been deleted. - * - * @var bool - */ - protected $deleted = false; - - /** - * Fire the job. - * - * @return void - */ - abstract public function fire(); - - /** - * Delete the job from the queue. - * - * @return void - */ - public function delete() - { - $this->deleted = true; - } - - /** - * Determine if the job has been deleted. - * - * @return bool - */ - public function isDeleted() - { - return $this->deleted; - } - - /** - * Release the job back into the queue. - * - * @param int $delay - * @return void - */ - abstract public function release($delay = 0); - - /** - * Get the number of times the job has been attempted. - * - * @return int - */ - abstract public function attempts(); - - /** - * Get the raw body string for the job. - * - * @return string - */ - abstract public function getRawBody(); - - /** - * Resolve and fire the job handler method. - * - * @param array $payload - * @return void - */ - protected function resolveAndFire(array $payload) - { - list($class, $method) = $this->parseJob($payload['job']); - - $this->instance = $this->resolve($class); - - $this->instance->{$method}($this, $payload['data']); - } - - /** - * Resolve the given job handler. - * - * @param string $class - * @return mixed - */ - protected function resolve($class) - { - return $this->container->make($class); - } - - /** - * Parse the job declaration into class and method. - * - * @param string $job - * @return array - */ - protected function parseJob($job) - { - $segments = explode('@', $job); - - return count($segments) > 1 ? $segments : array($segments[0], 'fire'); - } - - /** - * Determine if job should be auto-deleted. - * - * @return bool - */ - public function autoDelete() - { - return isset($this->instance->delete); - } - - /** - * Calculate the number of seconds with the given delay. - * - * @param \DateTime|int $delay - * @return int - */ - protected function getSeconds($delay) - { - if ($delay instanceof DateTime) - { - return max(0, $delay->getTimestamp() - $this->getTime()); - } - - return (int) $delay; - } - - /** - * Get the current system time. - * - * @return int - */ - protected function getTime() - { - return time(); - } - - /** - * Get the name of the queued job class. - * - * @return string - */ - public function getName() - { - return json_decode($this->getRawBody(), true)['job']; - } - - /** - * Get the name of the queue the job belongs to. - * - * @return string - */ - public function getQueue() - { - return $this->queue; - } - -} http://git-wip-us.apache.org/repos/asf/airavata-php-gateway/blob/80fd786e/vendor/laravel/framework/src/Illuminate/Queue/Jobs/RedisJob.php ---------------------------------------------------------------------- diff --git a/vendor/laravel/framework/src/Illuminate/Queue/Jobs/RedisJob.php b/vendor/laravel/framework/src/Illuminate/Queue/Jobs/RedisJob.php deleted file mode 100644 index 93fba74..0000000 --- a/vendor/laravel/framework/src/Illuminate/Queue/Jobs/RedisJob.php +++ /dev/null @@ -1,134 +0,0 @@ -<?php namespace Illuminate\Queue\Jobs; - -use Illuminate\Queue\RedisQueue; -use Illuminate\Container\Container; - -class RedisJob extends Job { - - /** - * The Redis queue instance. - * - * @var \Illuminate\Queue\RedisQueue - */ - protected $redis; - - /** - * The Redis job payload. - * - * @var string - */ - protected $job; - - /** - * Create a new job instance. - * - * @param \Illuminate\Container\Container $container - * @param \Illuminate\Queue\RedisQueue $redis - * @param string $job - * @param string $queue - * @return void - */ - public function __construct(Container $container, RedisQueue $redis, $job, $queue) - { - $this->job = $job; - $this->redis = $redis; - $this->queue = $queue; - $this->container = $container; - } - - /** - * Fire the job. - * - * @return void - */ - public function fire() - { - $this->resolveAndFire(json_decode($this->getRawBody(), true)); - } - - /** - * Get the raw body string for the job. - * - * @return string - */ - public function getRawBody() - { - return $this->job; - } - - /** - * Delete the job from the queue. - * - * @return void - */ - public function delete() - { - parent::delete(); - - $this->redis->deleteReserved($this->queue, $this->job); - } - - /** - * Release the job back into the queue. - * - * @param int $delay - * @return void - */ - public function release($delay = 0) - { - $this->delete(); - - $this->redis->release($this->queue, $this->job, $delay, $this->attempts() + 1); - } - - /** - * Get the number of times the job has been attempted. - * - * @return int - */ - public function attempts() - { - return array_get(json_decode($this->job, true), 'attempts'); - } - - /** - * Get the job identifier. - * - * @return string - */ - public function getJobId() - { - return array_get(json_decode($this->job, true), 'id'); - } - - /** - * Get the IoC container instance. - * - * @return \Illuminate\Container\Container - */ - public function getContainer() - { - return $this->container; - } - - /** - * Get the underlying queue driver instance. - * - * @return \Illuminate\Redis\Database - */ - public function getRedisQueue() - { - return $this->redis; - } - - /** - * Get the underlying Redis job. - * - * @return string - */ - public function getRedisJob() - { - return $this->job; - } - -} http://git-wip-us.apache.org/repos/asf/airavata-php-gateway/blob/80fd786e/vendor/laravel/framework/src/Illuminate/Queue/Jobs/SqsJob.php ---------------------------------------------------------------------- diff --git a/vendor/laravel/framework/src/Illuminate/Queue/Jobs/SqsJob.php b/vendor/laravel/framework/src/Illuminate/Queue/Jobs/SqsJob.php deleted file mode 100755 index 0e666bd..0000000 --- a/vendor/laravel/framework/src/Illuminate/Queue/Jobs/SqsJob.php +++ /dev/null @@ -1,139 +0,0 @@ -<?php namespace Illuminate\Queue\Jobs; - -use Aws\Sqs\SqsClient; -use Illuminate\Container\Container; - -class SqsJob extends Job { - - /** - * The Amazon SQS client instance. - * - * @var \Aws\Sqs\SqsClient - */ - protected $sqs; - - /** - * The Amazon SQS job instance. - * - * @var array - */ - protected $job; - - /** - * Create a new job instance. - * - * @param \Illuminate\Container\Container $container - * @param \Aws\Sqs\SqsClient $sqs - * @param string $queue - * @param array $job - * @return void - */ - public function __construct(Container $container, - SqsClient $sqs, - $queue, - array $job) - { - $this->sqs = $sqs; - $this->job = $job; - $this->queue = $queue; - $this->container = $container; - } - - /** - * Fire the job. - * - * @return void - */ - public function fire() - { - $this->resolveAndFire(json_decode($this->getRawBody(), true)); - } - - /** - * Get the raw body string for the job. - * - * @return string - */ - public function getRawBody() - { - return $this->job['Body']; - } - - /** - * Delete the job from the queue. - * - * @return void - */ - public function delete() - { - parent::delete(); - - $this->sqs->deleteMessage(array( - - 'QueueUrl' => $this->queue, 'ReceiptHandle' => $this->job['ReceiptHandle'], - - )); - } - - /** - * Release the job back into the queue. - * - * @param int $delay - * @return void - */ - public function release($delay = 0) - { - // SQS job releases are handled by the server configuration... - } - - /** - * Get the number of times the job has been attempted. - * - * @return int - */ - public function attempts() - { - return (int) $this->job['Attributes']['ApproximateReceiveCount']; - } - - /** - * Get the job identifier. - * - * @return string - */ - public function getJobId() - { - return $this->job['MessageId']; - } - - /** - * Get the IoC container instance. - * - * @return \Illuminate\Container\Container - */ - public function getContainer() - { - return $this->container; - } - - /** - * Get the underlying SQS client instance. - * - * @return \Aws\Sqs\SqsClient - */ - public function getSqs() - { - return $this->sqs; - } - - /** - * Get the underlying raw SQS job. - * - * @return array - */ - public function getSqsJob() - { - return $this->job; - } - -} http://git-wip-us.apache.org/repos/asf/airavata-php-gateway/blob/80fd786e/vendor/laravel/framework/src/Illuminate/Queue/Jobs/SyncJob.php ---------------------------------------------------------------------- diff --git a/vendor/laravel/framework/src/Illuminate/Queue/Jobs/SyncJob.php b/vendor/laravel/framework/src/Illuminate/Queue/Jobs/SyncJob.php deleted file mode 100755 index fe02312..0000000 --- a/vendor/laravel/framework/src/Illuminate/Queue/Jobs/SyncJob.php +++ /dev/null @@ -1,97 +0,0 @@ -<?php namespace Illuminate\Queue\Jobs; - -use Closure; -use Illuminate\Container\Container; - -class SyncJob extends Job { - - /** - * The class name of the job. - * - * @var string - */ - protected $job; - - /** - * The queue message data. - * - * @var string - */ - protected $data; - - /** - * Create a new job instance. - * - * @param \Illuminate\Container\Container $container - * @param string $job - * @param string $data - * @return void - */ - public function __construct(Container $container, $job, $data = '') - { - $this->job = $job; - $this->data = $data; - $this->container = $container; - } - - /** - * Fire the job. - * - * @return void - */ - public function fire() - { - $data = json_decode($this->data, true); - - if ($this->job instanceof Closure) - { - call_user_func($this->job, $this, $data); - } - else - { - $this->resolveAndFire(array('job' => $this->job, 'data' => $data)); - } - } - - /** - * Get the raw body string for the job. - * - * @return string - */ - public function getRawBody() - { - // - } - - /** - * Release the job back into the queue. - * - * @param int $delay - * @return void - */ - public function release($delay = 0) - { - // - } - - /** - * Get the number of times the job has been attempted. - * - * @return int - */ - public function attempts() - { - return 1; - } - - /** - * Get the job identifier. - * - * @return string - */ - public function getJobId() - { - return ''; - } - -} http://git-wip-us.apache.org/repos/asf/airavata-php-gateway/blob/80fd786e/vendor/laravel/framework/src/Illuminate/Queue/Listener.php ---------------------------------------------------------------------- diff --git a/vendor/laravel/framework/src/Illuminate/Queue/Listener.php b/vendor/laravel/framework/src/Illuminate/Queue/Listener.php deleted file mode 100755 index edf3cda..0000000 --- a/vendor/laravel/framework/src/Illuminate/Queue/Listener.php +++ /dev/null @@ -1,238 +0,0 @@ -<?php namespace Illuminate\Queue; - -use Closure; -use Symfony\Component\Process\Process; - -class Listener { - - /** - * The command working path. - * - * @var string - */ - protected $commandPath; - - /** - * The environment the workers should run under. - * - * @var string - */ - protected $environment; - - /** - * The amount of seconds to wait before polling the queue. - * - * @var int - */ - protected $sleep = 3; - - /** - * The amount of times to try a job before logging it failed. - * - * @var int - */ - protected $maxTries = 0; - - /** - * The queue worker command line. - * - * @var string - */ - protected $workerCommand; - - /** - * The output handler callback. - * - * @var \Closure|null - */ - protected $outputHandler; - - /** - * Create a new queue listener. - * - * @param string $commandPath - * @return void - */ - public function __construct($commandPath) - { - $this->commandPath = $commandPath; - $this->workerCommand = '"'.PHP_BINARY.'" artisan queue:work %s --queue="%s" --delay=%s --memory=%s --sleep=%s --tries=%s'; - } - - /** - * Listen to the given queue connection. - * - * @param string $connection - * @param string $queue - * @param string $delay - * @param string $memory - * @param int $timeout - * @return void - */ - public function listen($connection, $queue, $delay, $memory, $timeout = 60) - { - $process = $this->makeProcess($connection, $queue, $delay, $memory, $timeout); - - while(true) - { - $this->runProcess($process, $memory); - } - } - - /** - * Run the given process. - * - * @param \Symfony\Component\Process\Process $process - * @param int $memory - * @return void - */ - public function runProcess(Process $process, $memory) - { - $process->run(function($type, $line) - { - $this->handleWorkerOutput($type, $line); - }); - - // Once we have run the job we'll go check if the memory limit has been - // exceeded for the script. If it has, we will kill this script so a - // process managers will restart this with a clean slate of memory. - if ($this->memoryExceeded($memory)) - { - $this->stop(); return; - } - } - - /** - * Create a new Symfony process for the worker. - * - * @param string $connection - * @param string $queue - * @param int $delay - * @param int $memory - * @param int $timeout - * @return \Symfony\Component\Process\Process - */ - public function makeProcess($connection, $queue, $delay, $memory, $timeout) - { - $string = $this->workerCommand; - - // If the environment is set, we will append it to the command string so the - // workers will run under the specified environment. Otherwise, they will - // just run under the production environment which is not always right. - if (isset($this->environment)) - { - $string .= ' --env='.$this->environment; - } - - // Next, we will just format out the worker commands with all of the various - // options available for the command. This will produce the final command - // line that we will pass into a Symfony process object for processing. - $command = sprintf( - $string, $connection, $queue, $delay, - $memory, $this->sleep, $this->maxTries - ); - - return new Process($command, $this->commandPath, null, null, $timeout); - } - - /** - * Handle output from the worker process. - * - * @param int $type - * @param string $line - * @return void - */ - protected function handleWorkerOutput($type, $line) - { - if (isset($this->outputHandler)) - { - call_user_func($this->outputHandler, $type, $line); - } - } - - /** - * Determine if the memory limit has been exceeded. - * - * @param int $memoryLimit - * @return bool - */ - public function memoryExceeded($memoryLimit) - { - return (memory_get_usage() / 1024 / 1024) >= $memoryLimit; - } - - /** - * Stop listening and bail out of the script. - * - * @return void - */ - public function stop() - { - die; - } - - /** - * Set the output handler callback. - * - * @param \Closure $outputHandler - * @return void - */ - public function setOutputHandler(Closure $outputHandler) - { - $this->outputHandler = $outputHandler; - } - - /** - * Get the current listener environment. - * - * @return string - */ - public function getEnvironment() - { - return $this->environment; - } - - /** - * Set the current environment. - * - * @param string $environment - * @return void - */ - public function setEnvironment($environment) - { - $this->environment = $environment; - } - - /** - * Get the amount of seconds to wait before polling the queue. - * - * @return int - */ - public function getSleep() - { - return $this->sleep; - } - - /** - * Set the amount of seconds to wait before polling the queue. - * - * @param int $sleep - * @return void - */ - public function setSleep($sleep) - { - $this->sleep = $sleep; - } - - /** - * Set the amount of times to try a job before logging it failed. - * - * @param int $tries - * @return void - */ - public function setMaxTries($tries) - { - $this->maxTries = $tries; - } - -} http://git-wip-us.apache.org/repos/asf/airavata-php-gateway/blob/80fd786e/vendor/laravel/framework/src/Illuminate/Queue/Queue.php ---------------------------------------------------------------------- diff --git a/vendor/laravel/framework/src/Illuminate/Queue/Queue.php b/vendor/laravel/framework/src/Illuminate/Queue/Queue.php deleted file mode 100755 index e6cd428..0000000 --- a/vendor/laravel/framework/src/Illuminate/Queue/Queue.php +++ /dev/null @@ -1,139 +0,0 @@ -<?php namespace Illuminate\Queue; - -use Closure; -use DateTime; -use Illuminate\Container\Container; -use Illuminate\Encryption\Encrypter; -use Illuminate\Support\SerializableClosure; - -abstract class Queue { - - /** - * The IoC container instance. - * - * @var \Illuminate\Container\Container - */ - protected $container; - - /** - * Marshal a push queue request and fire the job. - * - * @throws \RuntimeException - */ - public function marshal() - { - throw new \RuntimeException("Push queues only supported by Iron."); - } - - /** - * Push an array of jobs onto the queue. - * - * @param array $jobs - * @param mixed $data - * @param string $queue - * @return mixed - */ - public function bulk($jobs, $data = '', $queue = null) - { - foreach ((array) $jobs as $job) - { - $this->push($job, $data, $queue); - } - } - - /** - * Create a payload string from the given job and data. - * - * @param string $job - * @param mixed $data - * @param string $queue - * @return string - */ - protected function createPayload($job, $data = '', $queue = null) - { - if ($job instanceof Closure) - { - return json_encode($this->createClosurePayload($job, $data)); - } - - return json_encode(array('job' => $job, 'data' => $data)); - } - - /** - * Create a payload string for the given Closure job. - * - * @param \Closure $job - * @param mixed $data - * @return string - */ - protected function createClosurePayload($job, $data) - { - $closure = $this->crypt->encrypt(serialize(new SerializableClosure($job))); - - return array('job' => 'IlluminateQueueClosure', 'data' => compact('closure')); - } - - /** - * Set additional meta on a payload string. - * - * @param string $payload - * @param string $key - * @param string $value - * @return string - */ - protected function setMeta($payload, $key, $value) - { - $payload = json_decode($payload, true); - - return json_encode(array_set($payload, $key, $value)); - } - - /** - * Calculate the number of seconds with the given delay. - * - * @param \DateTime|int $delay - * @return int - */ - protected function getSeconds($delay) - { - if ($delay instanceof DateTime) - { - return max(0, $delay->getTimestamp() - $this->getTime()); - } - - return (int) $delay; - } - - /** - * Get the current UNIX timestamp. - * - * @return int - */ - public function getTime() - { - return time(); - } - - /** - * Set the IoC container instance. - * - * @param \Illuminate\Container\Container $container - * @return void - */ - public function setContainer(Container $container) - { - $this->container = $container; - } - - /** - * Set the encrypter instance. - * - * @param \Illuminate\Encryption\Encrypter $crypt - * @return void - */ - public function setEncrypter(Encrypter $crypt) - { - $this->crypt = $crypt; - } - -} http://git-wip-us.apache.org/repos/asf/airavata-php-gateway/blob/80fd786e/vendor/laravel/framework/src/Illuminate/Queue/QueueInterface.php ---------------------------------------------------------------------- diff --git a/vendor/laravel/framework/src/Illuminate/Queue/QueueInterface.php b/vendor/laravel/framework/src/Illuminate/Queue/QueueInterface.php deleted file mode 100755 index 69f9241..0000000 --- a/vendor/laravel/framework/src/Illuminate/Queue/QueueInterface.php +++ /dev/null @@ -1,44 +0,0 @@ -<?php namespace Illuminate\Queue; - -interface QueueInterface { - - /** - * Push a new job onto the queue. - * - * @param string $job - * @param mixed $data - * @param string $queue - * @return mixed - */ - public function push($job, $data = '', $queue = null); - - /** - * Push a raw payload onto the queue. - * - * @param string $payload - * @param string $queue - * @param array $options - * @return mixed - */ - public function pushRaw($payload, $queue = null, array $options = array()); - - /** - * Push a new job onto the queue after a delay. - * - * @param \DateTime|int $delay - * @param string $job - * @param mixed $data - * @param string $queue - * @return mixed - */ - public function later($delay, $job, $data = '', $queue = null); - - /** - * Pop the next job off of the queue. - * - * @param string $queue - * @return \Illuminate\Queue\Jobs\Job|null - */ - public function pop($queue = null); - -}
