Logidav Docs

QueueProcessorCommand extends ContainerAwareCommand
in package
uses LockableTrait

Class QueueProcessorCommand

Table of Contents

Constants

MAX_MESSAGES_TO_PROCESS  = 100000
WAIT_BEFORE_RECONNECT_uS  = 5000000

Properties

$_processedMessages  : mixed
$entityManager  : EntityManagerInterface
$logService  : LogServiceInterface|null
$name  : null
$queueService  : QueueServiceInterface
$rabbitMqService  : RabbitMqService|null

Methods

__construct()  : mixed
QueueProcessorCommand constructor.
configure()  : mixed
Configure
execute()  : int|null
checkQueues()  : mixed
processMessageFromMagento()  : mixed
processQueues()  : mixed

Constants

Properties

Methods

__construct()

QueueProcessorCommand constructor.

public __construct([null $name = null ][, QueueServiceInterface|null $queueService = null ][, LogServiceInterface|null $logService = null ][, EntityManagerInterface|null $entityManager = null ][, RabbitMqService|null $rabbitMqService = null ]) : mixed
Parameters
$name : null = null
$queueService : QueueServiceInterface|null = null
$logService : LogServiceInterface|null = null
$entityManager : EntityManagerInterface|null = null
$rabbitMqService : RabbitMqService|null = null

execute()

protected execute(InputInterface $input, OutputInterface $output) : int|null
Parameters
$input : InputInterface
$output : OutputInterface
Tags
throws
Exception
Return values
int|null

processMessageFromMagento()

private processMessageFromMagento(mixed $message) : mixed
Parameters
$message : mixed

processQueues()

private processQueues(mixed $runCategory[, mixed $status = ['Pending', 'Processing'] ][, mixed $offset = 0 ][, mixed $limit = 500 ]) : mixed
Parameters
$runCategory : mixed
$status : mixed = ['Pending', 'Processing']
$offset : mixed = 0
$limit : mixed = 500 

        

        
    




    

    

                                

                

                                
    

        On this page

        
    


                

                            

            

    

        

            
Search results