protected function execute(InputInterface $input, OutputInterface $output)
    {
        $this->initialiseWorker($input, $output);
        $totalTasks = $input->getOption('total-tasks');
        for ($counter = 0; $counter < $totalTasks; $counter++) {
            $task = new ExampleTaskDescription();
            $task->message = 'hello world';
            $task->wait = 1;
            $this->taskQueueService->queueTask($task, $this->tube);
        }
    }