kaliop-uk / kueueingbundle-kinesis

Adapter/Kinesis/Consumer.php

Spacing +4 added lines, -4 removed lines

@@ -53,7 +53,7 @@ 
      */
     public function setCallback($callback)
     {
-        if (! $callback instanceof \Kaliop\QueueingBundle\Queue\MessageConsumerInterface) {
+        if (!$callback instanceof \Kaliop\QueueingBundle\Queue\MessageConsumerInterface) {
             throw new \RuntimeException('Can not set callback to SQS Consumer, as it is not a MessageConsumerInterface');
         }
         $this->callback = $callback;
@@ -107,7 +107,7 @@ 
      * @param int $timeout
      * @return nothing
      */
-    public function consume($amount, $timeout=0)
+    public function consume($amount, $timeout = 0)
     {
         $iterator = $this->getInitialMessageIterator();
 
@@ -117,7 +117,7 @@ 
             $remaining = $timeout;
         }
 
-        while(true) {
+        while (true) {
             $reqTime = microtime(true);
             $result = $this->client->getRecords(array(
                 'ShardIterator' => $iterator,
@@ -131,7 +131,7 @@ 
                 $this->sequenceNumberStore->save($this->streamName, $this->shardId, $last['SequenceNumber']);
             }
 
-            foreach($records as $record) {
+            foreach ($records as $record) {
                 $data = $record['Data'];
                 unset($record['Data']);
                 $this->callback->receive(new Message($data, $record));