poisonPillPut = $poisonPillPut; } /** * @inheritdoc */ protected function execute(InputInterface $input, OutputInterface $output) { $this->poisonPillPut->put(); return Cli::RETURN_SUCCESS; } /** * @inheritdoc */ protected function configure() { $this->setName(self::COMMAND_QUEUE_CONSUMERS_RESTART); $this->setDescription('Restart MessageQueue consumers'); $this->setHelp( <<