Gendoria / command-queue-doctrine-bundle

src/Gendoria/CommandQueueDoctrineDriverBundle/Worker/DoctrineWorkerRunner.php

Spacing +9 added lines, -9 removed lines

@@ -125,7 +125,7 @@ 
         
         $this->connection->setTransactionIsolation(Connection::TRANSACTION_SERIALIZABLE);
         
-        while ($this->checkRunTimes() && $this->runIteration($output, (bool)$this->options['exit_if_empty'])) {
+        while ($this->checkRunTimes() && $this->runIteration($output, (bool) $this->options['exit_if_empty'])) {
             $this->logger->debug('Doctrine worker tick.');
         }
     }
@@ -225,11 +225,11 @@ 
     {
         $platform = $this->connection->getDatabasePlatform();
         $sqlProto = "SELECT * "
-            . " FROM " . $platform->appendLockHint($this->tableName, LockMode::PESSIMISTIC_WRITE)
+            . " FROM ".$platform->appendLockHint($this->tableName, LockMode::PESSIMISTIC_WRITE)
             . " WHERE processed = ? AND pool = ? AND process_after <= ? "
             . " ORDER BY id ASC"
         ;
-        return $platform->modifyLimitQuery($sqlProto, 1) . " " . $platform->getWriteLockSQL();
+        return $platform->modifyLimitQuery($sqlProto, 1)." ".$platform->getWriteLockSQL();
     }
     
     /**
@@ -255,13 +255,13 @@ 
     {
         $parameters = array(
             'processed' => true,
-            'id' => (int)$id,
+            'id' => (int) $id,
         );
         $types = array(
             'processed' => 'boolean',
             'id' => 'smallint'
         );
-        $updateSql = "UPDATE " . $this->tableName
+        $updateSql = "UPDATE ".$this->tableName
             . " SET processed = :processed"
             . " WHERE id = :id";
         if ($this->connection->executeUpdate($updateSql, $parameters, $types) !== 1) {
@@ -280,9 +280,9 @@ 
     {
         $parameters = array(
             'processed' => false,
-            'failed_no' => (int)$failedRetries,
-            'id' => (int)$id,
-            'process_after' => new DateTime('@'.(time()+20*$failedRetries)),
+            'failed_no' => (int) $failedRetries,
+            'id' => (int) $id,
+            'process_after' => new DateTime('@'.(time()+20 * $failedRetries)),
         );
         $types = array(
             'processed' => 'boolean',
@@ -290,7 +290,7 @@ 
             'id' => 'smallint',
             'process_after' => 'datetime',
         );
-        $updateSql = "UPDATE " . $this->tableName
+        $updateSql = "UPDATE ".$this->tableName
             . " SET processed = :processed, failed_no = :failed_no, process_after = :process_after"
             . " WHERE id = :id";
         return $this->connection->executeUpdate($updateSql, $parameters, $types);