graze / queue

src/Message/MessageFactory.php

Doc Comments +1 added lines, -1 removed lines

@@ -28,7 +28,7 @@
     }
 
     /**
-     * @return callable
+     * @return ImmutableContainer
      */
     protected function getMetadata(array $options)
     {

Spacing +1 added lines, -1 removed lines

@@ -42,7 +42,7 @@
      */
     protected function getValidator(array $options)
     {
-        return isset($options['validator']) ? $options['validator'] : function (MessageInterface $message) {
+        return isset($options['validator']) ? $options['validator'] : function(MessageInterface $message) {
             return true;
         };
     }

src/Adapter/SqsAdapter.php

Spacing +9 added lines, -9 removed lines

@@ -104,14 +104,14 @@ 
                 'Entries' => $batch,
             ]);
 
-            $map = function ($result) use ($messages) {
+            $map = function($result) use ($messages) {
                 return $messages[$result['Id']];
             };
 
             $failed = array_merge($failed, array_map($map, $results->get('Failed') ?: []));
         }
 
-        if (! empty($failed)) {
+        if (!empty($failed)) {
             throw new FailedAcknowledgementException($this, $failed);
         }
     }
@@ -133,7 +133,7 @@ 
             $size = ($limit !== null) ? min($remaining, self::BATCHSIZE_RECEIVE) : self::BATCHSIZE_RECEIVE;
 
             $timestamp = time() + $this->getQueueVisibilityTimeout();
-            $validator = function () use ($timestamp) {
+            $validator = function() use ($timestamp) {
                 return time() < $timestamp;
             };
 
@@ -178,14 +178,14 @@ 
                 'Entries' => $batch,
             ]);
 
-            $map = function ($result) use ($messages) {
+            $map = function($result) use ($messages) {
                 return $messages[$result['Id']];
             };
 
             $failed = array_merge($failed, array_map($map, $results->get('Failed') ?: []));
         }
 
-        if (! empty($failed)) {
+        if (!empty($failed)) {
             throw new FailedEnqueueException($this, $failed);
         }
     }
@@ -213,7 +213,7 @@ 
      */
     protected function createDeleteEntries(array $messages)
     {
-        array_walk($messages, function (MessageInterface &$message, $id) {
+        array_walk($messages, function(MessageInterface&$message, $id) {
             $metadata = $message->getMetadata();
             $message = [
                 'Id' => $id,
@@ -231,7 +231,7 @@ 
      */
     protected function createEnqueueEntries(array $messages)
     {
-        array_walk($messages, function (MessageInterface &$message, $id) {
+        array_walk($messages, function(MessageInterface&$message, $id) {
             $metadata = $message->getMetadata();
             $message = [
                 'Id' => $id,
@@ -277,7 +277,7 @@ 
      */
     protected function getQueueUrl()
     {
-        if (! $this->url) {
+        if (!$this->url) {
             $result = $this->client->createQueue([
                 'QueueName' => $this->name,
                 'Attributes' => $this->options,
@@ -294,7 +294,7 @@ 
      */
     protected function getQueueVisibilityTimeout()
     {
-        if (! isset($this->options['VisibilityTimeout'])) {
+        if (!isset($this->options['VisibilityTimeout'])) {
             $result = $this->client->getQueueAttributes([
                 'QueueUrl' => $this->getQueueUrl(),
                 'AttributeNames' => ['VisibilityTimeout'],

src/Adapter/ArrayAdapter.php

Spacing +1 added lines, -1 removed lines

@@ -40,7 +40,7 @@
      */
     public function acknowledge(array $messages)
     {
-        $this->queue = array_values(array_filter($this->queue, function ($message) use ($messages) {
+        $this->queue = array_values(array_filter($this->queue, function($message) use ($messages) {
             return false === array_search($message, $messages, true);
         }));
     }

src/Handler/BatchAcknowledgementHandler.php

Spacing +1 added lines, -1 removed lines

@@ -58,7 +58,7 @@
      */
     protected function flush(AdapterInterface $adapter)
     {
-        if (! empty($this->messages)) {
+        if (!empty($this->messages)) {
             $adapter->acknowledge($this->messages);
 
             $this->messages = [];

src/Handler/AbstractAcknowledgementHandler.php

Spacing +1 added lines, -1 removed lines

@@ -47,7 +47,7 @@
     {
         // Used to break from polling consumer
         $break = false;
-        $done = function () use (&$break) {
+        $done = function() use (&$break) {
             $break = true;
         };