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