Fixing WS message processing conditions in ProcessWebsocketUpdatesCommand.

This commit is contained in:
Alexey Skobkin 2019-02-25 22:10:17 +03:00
parent b1d047941c
commit dbc1c060f8

View file

@ -84,13 +84,9 @@ class ProcessWebsocketUpdatesCommand extends Command
try { try {
if ($this->messageProcessor->processMessage($message)) { if ($this->messageProcessor->processMessage($message)) {
if ($keepJobs) { if (!$keepJobs) {
} else {
$this->bsClient->delete($job); $this->bsClient->delete($job);
} }
} else {
} }
} catch (UnsupportedTypeException $e) { } catch (UnsupportedTypeException $e) {
$output->writeln('Unsupported message type: '.$message->getA()); $output->writeln('Unsupported message type: '.$message->getA());