From 728464005eef43a8e98c29a6ea0e8048d0678cbf Mon Sep 17 00:00:00 2001 From: Alexey Skobkin Date: Mon, 25 Feb 2019 17:56:46 +0300 Subject: [PATCH] Small style changes in ProcessWebsocketUpdatesCommand. --- .../Command/ProcessWebsocketUpdatesCommand.php | 5 ++--- 1 file changed, 2 insertions(+), 3 deletions(-) diff --git a/src/Skobkin/Bundle/PointToolsBundle/Command/ProcessWebsocketUpdatesCommand.php b/src/Skobkin/Bundle/PointToolsBundle/Command/ProcessWebsocketUpdatesCommand.php index cb1b7ca..1b45cc8 100644 --- a/src/Skobkin/Bundle/PointToolsBundle/Command/ProcessWebsocketUpdatesCommand.php +++ b/src/Skobkin/Bundle/PointToolsBundle/Command/ProcessWebsocketUpdatesCommand.php @@ -8,8 +8,7 @@ use Pheanstalk\Job; use Skobkin\Bundle\PointToolsBundle\DTO\Api\WebSocket\Message; use Skobkin\Bundle\PointToolsBundle\Service\WebSocket\WebSocketMessageProcessor; use Symfony\Component\Console\Command\Command; -use Symfony\Component\Console\Input\InputInterface; -use Symfony\Component\Console\Input\InputOption; +use Symfony\Component\Console\Input\{InputInterface, InputOption}; use Symfony\Component\Console\Output\OutputInterface; /** @@ -82,7 +81,7 @@ class ProcessWebsocketUpdatesCommand extends Command $this->bsClient->delete($job); } } else { - // BS return to queue + $this->bsClient->release($job); } } }