skobkin/point-tools
1
1
Fork 0
Code Issues 4 Pull requests 1 Releases Activity

Small style changes in ProcessWebsocketUpdatesCommand.

Browse source
This commit is contained in:
Alexey Skobkin 2019-02-25 17:56:46 +03:00
parent 4ce5fe0ccb
commit 728464005e
1 changed files with 2 additions and 3 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

5
src/Skobkin/Bundle/PointToolsBundle/Command/ProcessWebsocketUpdatesCommand.php
View file

@ -8,8 +8,7 @@ use Pheanstalk\Job;
use Skobkin\Bundle\PointToolsBundle\DTO\Api\WebSocket\Message; use Skobkin\Bundle\PointToolsBundle\DTO\Api\WebSocket\Message;
use Skobkin\Bundle\PointToolsBundle\Service\WebSocket\WebSocketMessageProcessor; use Skobkin\Bundle\PointToolsBundle\Service\WebSocket\WebSocketMessageProcessor;
use Symfony\Component\Console\Command\Command; use Symfony\Component\Console\Command\Command;
use Symfony\Component\Console\Input\InputInterface; use Symfony\Component\Console\Input\{InputInterface, InputOption};
use Symfony\Component\Console\Input\InputOption;
use Symfony\Component\Console\Output\OutputInterface; use Symfony\Component\Console\Output\OutputInterface;
/** /**
@ -82,7 +81,7 @@ class ProcessWebsocketUpdatesCommand extends Command
$this->bsClient->delete($job); $this->bsClient->delete($job);
} }
} else { } else {
// BS return to queue $this->bsClient->release($job);
} }
} }
} }