puzzle-org / amqp

src/Messages/Processors/GZip.php

Doc Comments +12 added lines

@@ -55,11 +55,17 @@ 
         return $this;
     }
     
+    /**
+     * @param integer $level
+     */
     private function isCompressionLevelValid($level)
     {
         return is_numeric($level) && $level >= -1 && $level <= 9;
     }
     
+    /**
+     * @param string $message
+     */
     private function logWarning($message)
     {
         $this->logger->warning(sprintf(
@@ -98,6 +104,9 @@ 
         $this->updateCompressedMessage($message, $compressedContent);
     }
     
+    /**
+     * @param string $compressedContent
+     */
     private function updateCompressedMessage(WritableMessage $message, $compressedContent)
     {
         $message->addHeaders([
@@ -134,6 +143,9 @@ 
         return false;
     }
     
+    /**
+     * @param string $uncompressedContent
+     */
     private function updateUncompressedMessage(ReadableMessage $message, $uncompressedContent)
     {
         $builder = new ReadableMessageModifier($message);

Spacing +2 added lines, -2 removed lines

@@ -40,7 +40,7 @@ 
      */
     public function setCompressionLevel($compressionLevel = -1)
     {
-        if(! $this->isCompressionLevelValid($compressionLevel))
+        if( ! $this->isCompressionLevelValid($compressionLevel))
         {
             $this->logWarning(sprintf(
                 "Invalid compression level (%s)",
@@ -71,7 +71,7 @@ 
     
     public function setEncodingMode($mode)
     {
-        if(! is_scalar($mode) || ! in_array($mode, [FORCE_GZIP, FORCE_DEFLATE]))
+        if( ! is_scalar($mode) || ! in_array($mode, [FORCE_GZIP, FORCE_DEFLATE]))
         {
             $this->logWarning(sprintf(
                 "Invalid encoding mode (%s)",

src/Workers/ReadableMessageModifier.php

Spacing +1 added lines, -1 removed lines

@@ -19,7 +19,7 @@
     {
         $this->originalMessage = $originalMessage;
         
-        $this->newRoutingKey= $originalMessage->getRoutingKey();
+        $this->newRoutingKey = $originalMessage->getRoutingKey();
         $this->newBody = null;
         
         $this->newAttributeValues = [];