Gendoria / command-queue-doctrine-bundle

src/Gendoria/CommandQueueDoctrineDriverBundle/Worker/DoctrineWorkerRunner.php

Spacing +9 added lines, -9 removed lines

@@ -110,7 +110,7 @@ 
     public function run(array $options, OutputInterface $output = null)
     {
         $this->options = $options;
-        $runTimes = !empty($options['run_times']) ? (int)$options['run_times'] : null;
+        $runTimes = !empty($options['run_times']) ? (int) $options['run_times'] : null;
         $output->writeln(sprintf("Worker run with options: %s", print_r($options, true)));
         $this->logger->debug(sprintf("Worker run with options: %s", print_r($options, true)));
         
@@ -196,11 +196,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 (!$row) {
@@ -248,13 +248,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);
@@ -271,9 +271,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',
@@ -281,7 +281,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);

src/Gendoria/CommandQueueDoctrineDriverBundle/SendDriver/DoctrineSendDriver.php

Spacing +2 added lines, -2 removed lines

@@ -55,8 +55,8 @@
     {
         $this->serializer = $serializer;
         $this->connection = $connection;
-        $this->tableName = (string)$tableName;
-        $this->pool = (string)$pool;
+        $this->tableName = (string) $tableName;
+        $this->pool = (string) $pool;
     }
 
     /**