simple-php-queue/src/Storage/StorageFactory.php at 20775b34a5b8089c72559230b9d2a988ae4453a2 · slowmove/simple-php-queue · GitHub

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
<?php

namespace Slowmove\SimplePhpQueue\Storage;

use Slowmove\SimplePhpQueue\Storage\Adapters\BeanstalkdStorage;
use Slowmove\SimplePhpQueue\Storage\Adapters\FileStorage;
use Slowmove\SimplePhpQueue\Storage\Adapters\RedisStorage;
use Slowmove\SimplePhpQueue\Storage\Adapters\SqliteStorage;

class StorageFactory
{
  public static function getStorage(StorageType $type, string $storagePath = "", string $storageName = 'queue'): StorageInterface
  {
    return match ($type) {
      StorageType::FILE       => new FileStorage($storagePath, $storageName),
      StorageType::SQLITE     => new SqliteStorage($storagePath, $storageName),
      StorageType::REDIS      => new RedisStorage($storagePath, $storageName),
      StorageType::BEANSTALKD => new BeanstalkdStorage($storagePath, $storageName),
    };
  }
}