QueueFake
class QueueFake extends QueueManager implements Queue (View source)
Свойства
| ReflectsClosures |
Свойства
| protected Application | $app | Экземпляр приложения. | from QueueManager |
| protected array | $connections | Массив разрешённых подключений к очереди. | from QueueManager |
| protected array | $connectors | Массив разрешённых соединителей очереди. | from QueueManager |
| protected array | $jobs | Все задачи, которые были помещены в очередь. |
Методы
| void | __construct(Application $app)
Создать новый экземпляр менеджера очереди. | from QueueManager |
| void | before(mixed $callback)
Зарегистрировать обработчик событий для события before job. | from QueueManager |
| void | after(mixed $callback)
Зарегистрировать обработчик событий для события after job. | from QueueManager |
| void | exceptionOccurred(mixed $callback)
Зарегистрировать обработчик событий для события возникновения исключения в задаче. | from QueueManager |
| void | looping(mixed $callback)
Зарегистрировать обработчик событий для цикла очереди демона. | from QueueManager |
| void | failing(mixed $callback)
Зарегистрировать обработчик событий для события неудачной задачи. | from QueueManager |
| void | stopping(mixed $callback)
Зарегистрировать обработчик событий для остановки очереди демона. | from QueueManager |
| bool | connected(string|null $name = null)
Определить, подключен ли драйвер. | from QueueManager |
| Queue | connection(mixed $value = null)
Разрешить экземпляр подключения к очереди. | |
| Queue | resolve(string $name)
Разрешить подключение к очереди. | from QueueManager |
| ConnectorInterface | getConnector(string $driver)
Получить соединитель для данного драйвера. | from QueueManager |
| void | extend(string $driver, Closure $resolver)
Добавить решатель подключения к очереди. | from QueueManager |
| void | addConnector(string $driver, Closure $resolver)
Добавить решатель подключения к очереди. | from QueueManager |
| array | getConfig(string $name)
Получить конфигурацию подключения к очереди. | from QueueManager |
| string | getDefaultDriver()
Получить имя подключения к очереди по умолчанию. | from QueueManager |
| void | setDefaultDriver(string $name)
Установить имя подключения к очереди по умолчанию. | from QueueManager |
| string | getName(string|null $connection = null)
Получить полное имя для данного соединения. | from QueueManager |
| mixed | __call(string $method, array $parameters)
Переопределить QueueManager, чтобы предотвратить циклическую зависимость. | |
| array | closureParameterTypes(Closure $closure)
Получить имена классов / типы параметров данного Closure. | from ReflectsClosures |
| string | firstClosureParameterType(Closure $closure)
Получить имя класса первого параметра данного Closure. | from ReflectsClosures |
| void | assertPushed(string|Closure $job, callable|int|null $callback = null)
Утверждать, что задача была отправлена на основе обратного вызова проверки истинности. | |
| void | assertPushedTimes(string $job, int $times = 1)
Утверждать, что задача была отправлена определенное количество раз. | |
| void | assertPushedOn(string $queue, string|Closure $job, callable|null $callback = null)
Утверждать, что задача была отправлена на основе обратного вызова проверки истинности. | |
| void | assertPushedWithChain(string $job, array $expectedChain = [], callable|null $callback = null)
Утверждать, что задача была отправлена со связанными задачами на основе обратного вызова проверки истинности. | |
| void | assertPushedWithoutChain(string $job, callable|null $callback = null)
Утверждать, что задача была отправлена с пустой цепочкой на основе обратного вызова проверки истинности. | |
| void | assertPushedWithChainOfObjects(string $job, array $expectedChain, callable|null $callback)
Утверждать, что задача была отправлена со связанными задачами на основе обратного вызова проверки истинности. | |
| void | assertPushedWithChainOfClasses(string $job, array $expectedChain, callable|null $callback)
Утверждать, что задача была отправлена со связанными задачами на основе обратного вызова проверки истинности. | |
| bool | isChainOfObjects(array $chain)
Определить, состоит ли данная цепочка полностью из объектов. | |
| void | assertNotPushed(string|Closure $job, callable|null $callback = null)
Определить, была ли отправлена задача на основе обратного вызова проверки истинности. | |
| void | assertNothingPushed()
Утверждать, что задачи не были отправлены. | |
| Collection | pushed(string $job, callable|null $callback = null)
Получить все задачи, соответствующие обратному вызову проверки истинности. | |
| bool | hasPushed(string $job)
Определить, есть ли какие-либо сохраненные задачи для данного класса. | |
| int | size(string|null $queue = null)
Получить размер очереди. |
| mixed | push(string|object $job, mixed $data = '', string|null $queue = null)
Отправить новую задачу в очередь. | |
| mixed | pushRaw(string $payload, string|null $queue = null, array $options = [])
Отправить сырое содержимое в очередь. | |
| mixed | later(DateTimeInterface|DateInterval|int $delay, string|object $job, mixed $data = '', string|null $queue = null)
Отправить новую задачу в очередь после задержки. | |
| mixed | pushOn(string $queue, string|object $job, mixed $data = '')
Отправить новую задачу в очередь. | |
| mixed | laterOn(string $queue, DateTimeInterface|DateInterval|int $delay, string|object $job, mixed $data = '')
Отправить новую задачу в очередь после задержки. | |
| Job|null | pop(string|null $queue = null)
Извлечь следующую задачу из очереди. | |
| mixed | bulk(array $jobs, mixed $data = '', string|null $queue = null)
Отправить массив задач в очередь. | |
| array | pushedJobs()
Получить отправленные задачи. | |
| string | getConnectionName()
Получить имя подключения для очереди. | |
| $this | setConnectionName(string $name)
Установить имя подключения для очереди. |
Подробности
void __construct(Application $app)
Создать новый менеджер очереди.
void before(mixed $callback)
Зарегистрировать обработчик события перед выполнением задачи.
void after(mixed $callback)
Зарегистрировать обработчик события после выполнения задачи.
void exceptionOccurred(mixed $callback)
Зарегистрировать обработчик события возникновения исключения при выполнении задачи.
void looping(mixed $callback)
Зарегистрировать обработчик события цикла работы демона очереди.
void failing(mixed $callback)
Зарегистрировать обработчик события сбоя задачи.
void stopping(mixed $callback)
Зарегистрировать обработчик события остановки демона очереди.
bool connected(string|null $name = null)
Определить, подключен ли драйвер.
Очередь connection(mixed $value = null)
Получить экземпляр подключения к очереди.
protected Очередь resolve(string $name)
Получить подключение к очереди.
protected Интерфейс соединителя getConnector(string $driver)
Получить соединитель для заданного драйвера.
void extend(string $driver, Closure $resolver)
Добавить разрешитель подключения к очереди.
void addConnector(string $driver, Closure $resolver)
Добавить разрешитель подключения к очереди.
protected array getConfig(string $name)
Получить конфигурацию подключения к очереди.
string getDefaultDriver()
Получить имя по умолчанию для подключения к очереди.
void setDefaultDriver(string $name)
Установите имя соединения по умолчанию для очереди.
string getName(string|null $connection = null)
Получить полное имя для заданного соединения.
mixed __call(string $method, array $parameters)
Переопределите QueueManager для предотвращения циклической зависимости.
protected array closureParameterTypes(Closure $closure)
Получить имена/типы параметров заданного Closure.
protected string firstClosureParameterType(Closure $closure)
Получить имя класса первого параметра заданного Closure.
void assertPushed(string|Closure $job, callable|int|null $callback = null)
Проверить, был ли отправлен Job на основе callback-функции проверки.
protected void assertPushedTimes(string $job, int $times = 1)
Проверить, был ли Job отправлен заданное количество раз.
void assertPushedOn(string $queue, string|Closure $job, callable|null $callback = null)
Проверить, был ли Job отправлен на определенную очередь, используя callback-функцию.
void assertPushedWithChain(string $job, array $expectedChain = [], callable|null $callback = null)
Проверить, был ли Job отправлен с цепочкой заданных Jobs, используя callback-функцию.
void assertPushedWithoutChain(string $job, callable|null $callback = null)
Проверить, был ли Job отправлен без цепочки, используя callback-функцию.
protected void assertPushedWithChainOfObjects(string $job, array $expectedChain, callable|null $callback)
Проверить, был ли Job отправлен с цепочкой объектов, используя callback-функцию.
protected void assertPushedWithChainOfClasses(string $job, array $expectedChain, callable|null $callback)
Проверить, был ли Job отправлен с цепочкой классов, используя callback-функцию.
protected bool isChainOfObjects(array $chain)
Определить, состоит ли цепочка полностью из объектов.
void assertNotPushed(string|Closure $job, callable|null $callback = null)
Определить, был ли Job отправлен на основе callback-функции проверки.
void assertNothingPushed()
Проверить, что Jobs не были отправлены.
Collection pushed(string $job, callable|null $callback = null)
Получить все Jobs, соответствующие callback-функции проверки.
bool hasPushed(string $job)
Определить, есть ли сохраненные Jobs для заданного класса.
int size(string|null $queue = null)
Получить размер очереди.
mixed push(string|object $job, mixed $data = '', string|null $queue = null)
Добавить новую задачу в очередь.
mixed pushRaw(string $payload, string|null $queue = null, array $options = [])
Добавить сырые данные в очередь.
mixed later(DateTimeInterface|DateInterval|int $delay, string|object $job, mixed $data = '', string|null $queue = null)
Добавить новую задачу в очередь с задержкой.
mixed pushOn(string $queue, string|object $job, mixed $data = '')
Добавить новую задачу в очередь.
mixed laterOn(string $queue, DateTimeInterface|DateInterval|int $delay, string|object $job, mixed $data = '')
Добавить новую задачу в очередь с задержкой.
Job|null pop(string|null $queue = null)
Извлечь следующую задачу из очереди.
mixed bulk(array $jobs, mixed $data = '', string|null $queue = null)
Добавить массив задач в очередь.
array pushedJobs()
Получить добавленные задачи.
string getConnectionName()
Получить имя подключения к очереди.
$this setConnectionName(string $name)
Установить имя подключения к очереди.
© Taylor Otwell
Licensed under the MIT License.
Laravel is a trademark of Taylor Otwell.
https://laravel.com/api/7.x/Illuminate/Support/Testing/Fakes/QueueFake.html