kaliop-uk / kueueingbundle-sqs

Adapter/SQS/Producer.php

Doc Comments -1 removed lines

@@ -48,7 +48,6 @@
     }
 
     /**
-     * @param string $queueName NB: complete queue name as used by SQS
      * @return Producer
      * @todo test that we can successfully send messages to 2 queues using the same SqsClient
      */

Spacing +1 added lines, -1 removed lines

@@ -98,7 +98,7 @@
         for ($i = 0; $i < count($messages); $i += 10) {
             $entries = array();
             $toSend = array_slice($messages, $i, 10);
-            foreach($toSend as $message) {
+            foreach ($toSend as $message) {
                 $entries[] = array_merge(
                     array(
                         'MessageBody' => $message['msgBody'],

Adapter/SQS/Consumer.php

Spacing +7 added lines, -7 removed lines

@@ -92,7 +92,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;
@@ -128,7 +128,7 @@ 
      * @param int $timeout seconds
      * @return nothing
      */
-    public function consume($amount, $timeout=0)
+    public function consume($amount, $timeout = 0)
     {
         $limit = ($amount > 0) ? $amount : $this->requestBatchSize;
         if ($timeout > 0) {
@@ -143,7 +143,7 @@ 
             'MessageAttributeNames' => array('All')
         );
 
-        while(true) {
+        while (true) {
             $reqTime = microtime(true);
 
             if ($timeout > 0) {
@@ -155,13 +155,13 @@ 
             $messages = $result->get('Messages');
 
             if (is_array($messages)) {
-                foreach($messages as $message) {
+                foreach ($messages as $message) {
 
                     // How we implement routing keys with SQS: since it is not supported natively, we check if the route
                     // matches after having downloaded the message. If it does not match, we just skip processing it.
                     // Since we will not call deleteMessage, SQS will requeue the message in a short time.
                     // This is far from optimal, but it might be better than nothing
-                    if (! $this->matchRoutingKey($message)) {
+                    if (!$this->matchRoutingKey($message)) {
                         continue;
                     }
 
@@ -174,7 +174,7 @@ 
                     $data = $message['Body'];
                     unset($message['Body']);
 
-                    $contentType = isset( $message['MessageAttributes'][$this->contentTypeAttribute]['StringValue'] ) ?
+                    $contentType = isset($message['MessageAttributes'][$this->contentTypeAttribute]['StringValue']) ?
                         $message['MessageAttributes'][$this->contentTypeAttribute]['StringValue'] : '';
 
                     if ($contentType != '') {
@@ -282,7 +282,7 @@ 
             pcntl_signal_dispatch();
         }
 
-        if ($this->memoryLimit > 0 && !$this->forceStop && memory_get_usage(true) >= ($this->memoryLimit * 1024 * 1024) ) {
+        if ($this->memoryLimit > 0 && !$this->forceStop && memory_get_usage(true) >= ($this->memoryLimit * 1024 * 1024)) {
             $this->forceStop("Memory limit of {$this->memoryLimit} MB reached while consuming messages");
         }
 

Adapter/SQS/QueueManager.php

Spacing +3 added lines, -3 removed lines

@@ -43,7 +43,7 @@ 
         return array('list-available', 'list-configured', 'create', 'info', 'purge', 'delete');
     }
 
-    public function executeAction($action, array $arguments=array())
+    public function executeAction($action, array $arguments = array())
     {
         switch ($action) {
             case 'list-available':
@@ -145,11 +145,11 @@ 
 
     protected function getProducerService()
     {
-        return $this->container->get('kaliop_queueing.sqs.'. $this->queueName . '_producer');
+        return $this->container->get('kaliop_queueing.sqs.'.$this->queueName.'_producer');
     }
 
     public function registerQueue($queueName)
     {
-        $this->registeredQueues[]=$queueName;
+        $this->registeredQueues[] = $queueName;
     }
 }

Adapter/SQS/Driver.php

Spacing +2 added lines, -2 removed lines

@@ -101,7 +101,7 @@ 
      * @param string $scope
      * @return mixed
      */
-    public function createProducer($queueName, $queueUrl, $connectionId, $scope=ContainerInterface::SCOPE_CONTAINER)
+    public function createProducer($queueName, $queueUrl, $connectionId, $scope = ContainerInterface::SCOPE_CONTAINER)
     {
         $class = $this->container->getParameter('kaliop_queueing.sqs.producer.class');
         $producer = new $class($this->getConnectionConfig($connectionId));
@@ -121,7 +121,7 @@ 
      * @param string $scope
      * @return Consumer
      */
-    public function createConsumer($queueName, $queueUrl, $connectionId, $callback=null, $routingKey=null, $scope=ContainerInterface::SCOPE_CONTAINER)
+    public function createConsumer($queueName, $queueUrl, $connectionId, $callback = null, $routingKey = null, $scope = ContainerInterface::SCOPE_CONTAINER)
     {
         $class = $this->container->getParameter('kaliop_queueing.sqs.consumer.class');
         $consumer = new $class($this->getConnectionConfig($connectionId));