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)
Утверждение, что задача была помещена с цепочкой задач, основанной на обратном вызове проверки истинности. | |
| 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)
Определение, была ли задача помещена на основе обратного вызова проверки истинности. | |
| 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 = [])
Помещение сырого содержимого в очередь. | |
| 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/10.x/Illuminate/Support/Testing/Fakes/QueueFake.html
