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.');
         }
     }
@@ -204,11 +204,11 @@ 
         try {
             $this->connection->beginTransaction();
             $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"
             ;
-            $sql = $platform->modifyLimitQuery($sqlProto, 1) . " " . $platform->getWriteLockSQL();
+            $sql = $platform->modifyLimitQuery($sqlProto, 1)." ".$platform->getWriteLockSQL();
             $row = $this->connection->fetchAssoc($sql, array(0, $this->pool, new DateTime()), array('integer', 'string', 'datetime'));
 
             if (empty($row)) {
@@ -253,13 +253,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";
         return $this->connection->executeUpdate($updateSql, $parameters, $types);
@@ -276,9 +276,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',
@@ -286,7 +286,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);