ProductAvailabilityUpdateProcessor
in package
implements
QueueProcessorInterface
Class AvailabilityUpdateProcessor
Table of Contents
Interfaces
- QueueProcessorInterface
- Interface QueueProcessorInterface
Properties
- $container : ContainerInterface
- $entityManager : EntityManagerInterface
- $productApi : ProductApi
- $productService : ProductService
- $rabbitMqService : RabbitMqService
- $useApiInsteadOfRabbitMq : mixed
Methods
- __construct() : mixed
- ProductPriceUpdateProcessor constructor.
- execute() : array<string|int, mixed>
- Execute The Process
Properties
$container
private
ContainerInterface
$container
$entityManager
private
EntityManagerInterface
$entityManager
$productApi
private
ProductApi
$productApi
$productService
private
ProductService
$productService
$rabbitMqService
private
RabbitMqService
$rabbitMqService
$useApiInsteadOfRabbitMq
private
mixed
$useApiInsteadOfRabbitMq
= true
Methods
__construct()
ProductPriceUpdateProcessor constructor.
public
__construct(ContainerInterface $container, RabbitMqService $rabbitMqService, EntityManagerInterface $entityManager) : mixed
Parameters
- $container : ContainerInterface
- $rabbitMqService : RabbitMqService
- $entityManager : EntityManagerInterface
execute()
Execute The Process
public
execute(array<string|int, mixed> $queues) : array<string|int, mixed>
Parameters
- $queues : array<string|int, mixed>