Current path: home/webdevt/www/wdp/wp-content/plugins/caldera-forms/vendor/a5hleyrich/wp-queue/src/WP_Queue/
?? Go up: /home/webdevt/www/wdp/wp-content/plugins/caldera-forms/vendor/a5hleyrich/wp-queue/src
<?php
namespace WP_Queue;
use WP_Queue\Connections\DatabaseConnection;
use WP_Queue\Connections\RedisConnection;
use WP_Queue\Connections\SyncConnection;
use WP_Queue\Exceptions\ConnectionNotFoundException;
class QueueManager {
/**
* @var array
*/
protected static $instances = array();
/**
* Resolve a Queue instance for required connection.
*
* @param string $connection
*
* @return Queue
*/
public static function resolve( $connection ) {
if ( isset( static::$instances[ $connection ] ) ) {
return static::$instances[ $connection ];
}
return static::build( $connection );
}
/**
* Build a queue instance.
*
* @param string $connection
*
* @return Queue
* @throws \Exception
*/
protected static function build( $connection ) {
$connections = static::connections();
if ( empty( $connections[ $connection ] ) ) {
throw new ConnectionNotFoundException();
}
static::$instances[ $connection ] = new Queue( $connections[ $connection ] );
return static::$instances[ $connection ];
}
/**
* Get available connections.
*
* @return array
*/
protected static function connections() {
$connections = array(
'database' => new DatabaseConnection( $GLOBALS['wpdb'] ),
'redis' => new RedisConnection(),
'sync' => new SyncConnection(),
);
return apply_filters( 'wp_queue_connections', $connections );
}
}