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)
Создать новый экземпляр менеджера очереди. | из QueueManager |
| 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)
Получить имя класса первого параметра данного Closure. | из ReflectsClosures |
| array | firstClosureParameterTypes(Closure $closure)
Получить имена классов первого параметра данного Closure, включая типы объединения. | из ReflectsClosures |
| array | closureParameterTypes(Closure $closure)
Получить имена/типы классов параметров данного Closure. | из 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)
Определить, подключен ли драйвер.
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.
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)
Проверить, если задача была помещена в очередь с цепочкой задач на основе обратного вызова проверки истинности.
protected 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)
Установить имя подключения для очереди.
© Taylor Otwell
Licensed under the MIT License.
Laravel is a trademark of Taylor Otwell.
https://laravel.com/api/8.x/Illuminate/Support/Testing/Fakes/QueueFake.html
