QueueFake
класс QueueFake расширяет QueueManager и реализует Queue (Просмотреть исходный код)
Трейты
| ReflectsClosures |
Свойства
| protected Application | $app | Экземпляр приложения. | из QueueManager |
| protected массив | $connections | Массив разрешенных подключений очереди. | из QueueManager |
| protected массив | $connectors | Массив разрешенных соединителей очереди. | из QueueManager |
| protected Queue | $queue | Исходный менеджер очереди. | |
| protected Collection | $jobsToFake | Типы задач, которые должны быть перехвачены вместо помещения в очередь. | |
| protected Collection | $jobsToBeQueued | Типы задач, которые должны быть помещены в очередь и не перехватываются. | |
| protected массив | $jobs | Все задачи, которые были помещены в очередь. |
Методы
| void | __construct(Application $app, array $jobsToFake = [], QueueManager|null $queue = null)
Создать новый экземпляр фиктивной очереди. | |
| void | before(mixed $callback)
Зарегистрировать обработчик событий для события перед задачей. | from QueueManager |
| void | after(mixed $callback)
Зарегистрировать обработчик событий для события после задачи. | 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|null | getConfig(string $name)
Получить конфигурацию подключения к очереди. | from QueueManager |
| string | getDefaultDriver()
Получить имя подключения к очереди по умолчанию. | from QueueManager |
| void | setDefaultDriver(string $name)
Установить имя подключения к очереди по умолчанию. | from QueueManager |
| string | getName(string|null $connection = null)
Получить полное имя для данного подключения. | from QueueManager |
| Application | getApplication()
Получить экземпляр приложения, используемый менеджером. | from QueueManager |
| $this | setApplication(Application $app)
Установить экземпляр приложения, используемый менеджером. | from QueueManager |
| mixed | __call(string $method, array $parameters)
Переопределить QueueManager для предотвращения циклической зависимости. | |
| string | firstClosureParameterType(Closure $closure)
Получить имя класса первого параметра данного замыкания. | from ReflectsClosures |
| array | firstClosureParameterTypes(Closure $closure)
Получить имена классов первого параметра данного замыкания, включая типы объединения. | from ReflectsClosures |
| array | closureParameterTypes(Closure $closure)
Получить имена/типы классов параметров данного замыкания. | from 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 с цепочкой задач, основанной на callback-функции проверки. | |
| bool | isChainOfObjects(array $chain)
Определить, состоит ли заданная цепочка целиком из объектов. | |
| void | assertNotPushed(string|Closure $job, callable|null $callback = null)
Определить, был ли отправлен job, основываясь на callback-функции проверки. | |
| void | assertNothingPushed()
Проверить, что не было отправлено ни одного job. | |
| Collection | pushed(string $job, callable|null $callback = null)
Получить все job, соответствующие callback-функции проверки. | |
| 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()
Получить отправленные задачи. | |
| 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)
Определить, подключен ли драйвер.
Queue connection(mixed $value = null)
Получить экземпляр подключения к очереди.
protected Queue resolve(string $name)
Получить подключение к очереди.
protected ConnectorInterface 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)
Получить полное имя для заданного подключения.
Application getApplication()
Получить экземпляр приложения, используемый менеджером.
$this setApplication(Application $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)
Проверить, был ли отправлен в очередь job, основываясь на обратном вызове truth-test.
void assertPushedWithChain(string $job, array $expectedChain = [], callable|null $callback = null)
Проверить, был ли отправлен job с цепочкой зависимых задач, основываясь на обратном вызове truth-test.
void assertPushedWithoutChain(string $job, callable|null $callback = null)
Проверить, был ли отправлен job с пустой цепочкой, основываясь на обратном вызове truth-test.
protected void assertPushedWithChainOfObjects(string $job, array $expectedChain, callable|null $callback)
Проверить, был ли отправлен job с цепочкой зависимых задач, основываясь на обратном вызове truth-test.
protected void assertPushedWithChainOfClasses(string $job, array $expectedChain, callable|null $callback)
Проверить, был ли отправлен job с цепочкой зависимых задач, основываясь на обратном вызове truth-test.
protected bool isChainOfObjects(array $chain)
Определить, состоит ли данная цепочка целиком из объектов.
void assertNotPushed(string|Closure $job, callable|null $callback = null)
Определить, был ли job отправлен в очередь, основываясь на обратном вызове truth-test.
void assertNothingPushed()
Проверить, что задачи не были отправлены в очередь.
Collection pushed(string $job, callable|null $callback = null)
Получить все задачи, соответствующие обратного вызову truth-test.
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) секунд.
Задача|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/9.x/Illuminate/Support/Testing/Fakes/QueueFake.html
