comodojo / extender.framework

src/Comodojo/Extender/Workers/QueueWorker.php

Spacing +1 added lines, -1 removed lines

@@ -66,7 +66,7 @@
 
         if ( !empty($queue) ) {
 
-            $events->emit( new QueueEvent('process', null, $queue) );
+            $events->emit(new QueueEvent('process', null, $queue));
 
             $requests = $this->jobsToRequests($queue);
 

src/Comodojo/Extender/Task/Runner.php

Spacing +7 added lines, -7 removed lines

@@ -86,7 +86,7 @@ 
 
             $thetask = $this->table->get($task)->getInstance($name, $parameters);
 
-            $this->events->emit( new TaskEvent('start', $thetask) );
+            $this->events->emit(new TaskEvent('start', $thetask));
 
             $pid = $thetask->getPid();
 
@@ -107,7 +107,7 @@ 
 
                 $status = Worklog::STATUS_COMPLETE;
 
-                $this->events->emit( new TaskEvent('complete', $thetask) );
+                $this->events->emit(new TaskEvent('complete', $thetask));
 
             } catch (TaskException $te) {
 
@@ -115,7 +115,7 @@ 
 
                 $result = $te->getMessage();
 
-                $this->events->emit( new TaskEvent('abort', $thetask) );
+                $this->events->emit(new TaskEvent('abort', $thetask));
 
             } catch (Exception $e) {
 
@@ -123,11 +123,11 @@ 
 
                 $result = $e->getMessage();
 
-                $this->events->emit( new TaskEvent('error', $thetask) );
+                $this->events->emit(new TaskEvent('error', $thetask));
 
             }
 
-            $this->events->emit( new TaskEvent('stop', $thetask) );
+            $this->events->emit(new TaskEvent('stop', $thetask));
 
             $this->stopwatch->stop();
 
@@ -161,7 +161,7 @@ 
 
         ob_end_clean();
 
-        $this->events->emit( new TaskEvent(self::statusToEvent($status), $thetask, $result) );
+        $this->events->emit(new TaskEvent(self::statusToEvent($status), $thetask, $result));
 
         return $result;
 
@@ -270,7 +270,7 @@ 
 
     protected function statusToEvent($status) {
 
-        switch ($status) {
+        switch ( $status ) {
             case Worklog::STATUS_COMPLETE:
                 return 'complete';
                 break;

src/Comodojo/Extender/Queue/Manager.php

Spacing +4 added lines, -4 removed lines

@@ -79,11 +79,11 @@ 
 
     public function flush(array $queue) {
 
-        $this->getEvents()->emit( new QueueEvent('flush', null, $queue) );
+        $this->getEvents()->emit(new QueueEvent('flush', null, $queue));
 
         $em = $this->getEntityManager();
 
-        foreach ($queue as $record) {
+        foreach ( $queue as $record ) {
             $em->remove($record);
         }
 
@@ -109,7 +109,7 @@ 
 
         $records = [];
 
-        foreach ($queue as $name => $request) {
+        foreach ( $queue as $name => $request ) {
             $records[] = $request instanceof Request ? $this->doAddRequest($request, $em) : false;
         }
 
@@ -121,7 +121,7 @@ 
 
     protected function doAddRequest(Request $request, EntityManager $em) {
 
-        $this->getEvents()->emit( new QueueEvent('add', $request) );
+        $this->getEvents()->emit(new QueueEvent('add', $request));
 
         $record = new Queue();
         $record->setName($request->getName())->setRequest($request);