diff --git a/src/Skobkin/Bundle/PointToolsBundle/Command/ProcessWebsocketUpdatesCommand.php b/src/Skobkin/Bundle/PointToolsBundle/Command/ProcessWebsocketUpdatesCommand.php index 94c6433..7e5fba3 100644 --- a/src/Skobkin/Bundle/PointToolsBundle/Command/ProcessWebsocketUpdatesCommand.php +++ b/src/Skobkin/Bundle/PointToolsBundle/Command/ProcessWebsocketUpdatesCommand.php @@ -84,13 +84,9 @@ class ProcessWebsocketUpdatesCommand extends Command try { if ($this->messageProcessor->processMessage($message)) { - if ($keepJobs) { - - } else { + if (!$keepJobs) { $this->bsClient->delete($job); } - } else { - } } catch (UnsupportedTypeException $e) { $output->writeln('Unsupported message type: '.$message->getA());