kaliop-uk / kueueingbundle-kinesis

Adapter/Kinesis/Consumer.php

Spacing +3 added lines, -3 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;
@@ -112,7 +112,7 @@ 
 
         $limit = ($amount > 0) ? $amount : $this->requestBatchSize;
 
-        while(true) {
+        while (true) {
             $reqTime = microtime(true);
             $result = $this->client->getRecords(array(
                 'ShardIterator' => $iterator,
@@ -126,7 +126,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));