ConsumeMessagesCommand extends Command

Almost full version of the symfony command with the same name.

Attributes
#[AsCommand]
$name: 'messenger:consume'
$description: 'Consume messages'

Table of Contents

Methods

__construct()  : mixed
complete()  : void
getSubscribedSignals()  : array<string|int, mixed>
handleSignal()  : int|false
configure()  : void
execute()  : int
initialize()  : void
interact()  : void

Methods

__construct()

public __construct(MessageBusInterface $messageBus, ContainerInterface $receiverLocator, EventDispatcherInterface $eventDispatcher, ListenerProvider $listenerProvider, ContainerInterface $container, iterable<string|int, mixed> $receiverNamesIterator[, array<string|int, mixed> $busIds = [] ][, ContainerInterface|null $rateLimiterLocator = null ][, array<string|int, mixed>|null $signals = null ]) : mixed
Parameters
$messageBus : MessageBusInterface
$receiverLocator : ContainerInterface
$eventDispatcher : EventDispatcherInterface
$listenerProvider : ListenerProvider
$container : ContainerInterface
$receiverNamesIterator : iterable<string|int, mixed>
$busIds : array<string|int, mixed> = []
$rateLimiterLocator : ContainerInterface|null = null
$signals : array<string|int, mixed>|null = null

complete()

public complete(CompletionInput $input, CompletionSuggestions $suggestions) : void
Parameters
$input : CompletionInput
$suggestions : CompletionSuggestions

getSubscribedSignals()

public getSubscribedSignals() : array<string|int, mixed>
Return values
array<string|int, mixed>

handleSignal()

public handleSignal(int $signal[, int|false $previousExitCode = 0 ]) : int|false
Parameters
$signal : int
$previousExitCode : int|false = 0
Return values
int|false

execute()

protected execute(InputInterface $input, OutputInterface $output) : int
Parameters
$input : InputInterface
$output : OutputInterface
Return values
int

initialize()

protected initialize(InputInterface $input, OutputInterface $output) : void
Parameters
$input : InputInterface
$output : OutputInterface

interact()

protected interact(InputInterface $input, OutputInterface $output) : void
Parameters
$input : InputInterface
$output : OutputInterface 

        

        
    




    

    

                            

            

                            
    

        On this page

        
    


            

                    

        

    

        

            
Search results