kaliop-uk / kueueingbundle-kinesis

Adapter/Kinesis/Driver.php

Doc Comments +3 added lines

@@ -18,6 +18,9 @@
         return $consumer;
     }
 
+    /**
+     * @param string $queueName
+     */
     protected function getQueueCallback($queueName)
     {
         $callbacks = $this->container->getParameter('kaliop_queueing_kinesis.default.consumers');

Service/DoctrineCacheSequenceNumberStore.php

Spacing +1 added lines, -1 removed lines

@@ -14,7 +14,7 @@
 
     public function __construct(Cache $cacheService)
     {
-        $this->cache =  $cacheService;
+        $this->cache = $cacheService;
     }
 
     /**

Adapter/Kinesis/Consumer.php

Spacing +2 added lines, -2 removed lines

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

Adapter/Kinesis/Message.php

Spacing +1 added lines, -1 removed lines

@@ -10,7 +10,7 @@
     protected $properties = array();
     protected $contentType;
 
-    public function __construct($body, array $properties = array(), $contentType='application/json')
+    public function __construct($body, array $properties = array(), $contentType = 'application/json')
     {
         $this->body = $body;
         $this->properties = $properties;

Adapter/Kinesis/Producer.php

Spacing +1 added lines, -1 removed lines

@@ -102,7 +102,7 @@
      */
     public function setContentType($contentType)
     {
-        if($contentType != 'application/json') {
+        if ($contentType != 'application/json') {
             throw new \Exception("Unsupported content-type for message serialization: $contentType. Only 'application/json' is supported");
         }
 

Adapter/Kinesis/QueueManager.php

Spacing +1 added lines, -1 removed lines

@@ -44,7 +44,7 @@
         return array('info', 'list', 'delete');
     }
 
-    public function executeAction($action, array $arguments=array())
+    public function executeAction($action, array $arguments = array())
     {
         switch ($action) {
             case 'delete':