videlalvaro / php-amqplib

PhpAmqpLib/Channel/AbstractChannel.php

Doc Comments +12 added lines, -2 removed lines

@@ -70,7 +70,7 @@ 
 
     /**
      * @param AbstractConnection $connection
-     * @param $channel_id
+     * @param integer|null $channel_id
      * @throws \PhpAmqpLib\Exception\AMQPRuntimeException
      */
     public function __construct(AbstractConnection $connection, $channel_id)
@@ -234,7 +234,7 @@ 
      * @param $method_sig
      * @param string $args
      * @param null $pkt
-     * @return null|\PhpAmqpLib\Wire\AMQPWriter
+     * @return \PhpAmqpLib\Wire\AMQPWriter
      */
     protected function prepare_method_frame($method_sig, $args = '', $pkt = null)
     {
@@ -408,6 +408,10 @@ 
         $this->validate_frame($frame_type, 3, 'AMQP Content body');
     }
 
+    /**
+     * @param integer $expected_type
+     * @param string $expected_msg
+     */
     protected function validate_frame($frame_type, $expected_type, $expected_msg)
     {
         if ($frame_type != $expected_type) {
@@ -444,6 +448,9 @@ 
         return mb_substr($payload, 4, mb_strlen($payload, 'ASCII') - 4, 'ASCII');
     }
 
+    /**
+     * @param string $method_sig
+     */
     protected function should_dispatch_method($allowed_methods, $method_sig)
     {
         $PROTOCOL_CONSTANTS_CLASS = self::$PROTOCOL_CONSTANTS_CLASS;
@@ -453,6 +460,9 @@ 
             || in_array($method_sig, $PROTOCOL_CONSTANTS_CLASS::$CLOSE_METHODS);
     }
 
+    /**
+     * @param string $method_sig
+     */
     protected function maybe_wait_for_content($method_sig)
     {
         $PROTOCOL_CONSTANTS_CLASS = self::$PROTOCOL_CONSTANTS_CLASS;

Unused Use Statements -1 removed lines

@@ -4,7 +4,6 @@
 use PhpAmqpLib\Exception\AMQPBasicCancelException;
 use PhpAmqpLib\Exception\AMQPProtocolChannelException;
 use PhpAmqpLib\Exception\AMQPRuntimeException;
-use PhpAmqpLib\Helper\MiscHelper;
 use PhpAmqpLib\Message\AMQPMessage;
 use PhpAmqpLib\Wire\AMQPReader;
 use PhpAmqpLib\Wire\AMQPWriter;

PhpAmqpLib/Channel/AMQPChannel.php

Doc Comments +10 added lines, -6 removed lines

@@ -226,7 +226,7 @@ 
     }
 
     /**
-     * @param $active
+     * @param boolean $active
      */
     protected function x_flow_ok($active)
     {
@@ -634,7 +634,7 @@ 
      * Confirms a queue definition
      *
      * @param AMQPReader $args
-     * @return array
+     * @return string[]
      */
     protected function queue_declare_ok($args)
     {
@@ -783,7 +783,7 @@ 
      *
      * @param string $delivery_tag
      * @param bool $multiple
-     * @param $handler
+     * @param callable $handler
      */
     protected function internal_ack_handler($delivery_tag, $multiple, $handler)
     {
@@ -801,14 +801,18 @@ 
     }
 
     /**
-     * @param array $array
-     * @param $value
+     * @param AMQPMessage[] $array
+     * @param string $value
      * @return mixed
      */
     protected function get_keys_less_or_equal(array $array, $value)
     {
         $keys = array_reduce(
             array_keys($array),
+
+            /**
+             * @param string $key
+             */
             function ($keys, $key) use ($value) {
                 if (bccomp($key, $value, 0) <= 0) {
                     $keys[] = $key;
@@ -1418,7 +1422,7 @@ 
     /**
      * Helper method to get a particular method from $this->publishedMessages, removes it from the array and returns it.
      *
-     * @param $index
+     * @param string $index
      * @return AMQPMessage
      */
     protected function get_and_unset_message($index)

Unused Use Statements -1 removed lines

@@ -4,7 +4,6 @@
 use PhpAmqpLib\Exception\AMQPBasicCancelException;
 use PhpAmqpLib\Exception\AMQPProtocolChannelException;
 use PhpAmqpLib\Exception\AMQPRuntimeException;
-use PhpAmqpLib\Helper\MiscHelper;
 use PhpAmqpLib\Message\AMQPMessage;
 use PhpAmqpLib\Wire\AMQPReader;
 use PhpAmqpLib\Wire\AMQPWriter;

PhpAmqpLib/Connection/AbstractConnection.php

Doc Comments +5 added lines, -5 removed lines

@@ -435,7 +435,7 @@ 
     }
 
     /**
-     * @param $channel
+     * @param string $channel
      * @param $method_sig
      * @param string $args
      * @param null $pkt
@@ -454,7 +454,7 @@ 
      * @param $method_sig
      * @param string $args
      * @param AMQPWriter $pkt
-     * @return null|AMQPWriter
+     * @return AMQPWriter
      */
     protected function prepare_channel_method_frame($channel, $method_sig, $args = '', $pkt = null)
     {
@@ -769,9 +769,9 @@ 
 
     /**
      * @param $client_properties
-     * @param $mechanism
-     * @param $response
-     * @param $locale
+     * @param string $mechanism
+     * @param AMQPWriter $response
+     * @param string $locale
      */
     protected function x_start_ok($client_properties, $mechanism, $response, $locale)
     {

Unused Use Statements +1 added lines, -1 removed lines

@@ -1,8 +1,8 @@
 <?php
 namespace PhpAmqpLib\Connection;
 
-use PhpAmqpLib\Channel\AbstractChannel;
 use PhpAmqpLib\Channel\AMQPChannel;
+use PhpAmqpLib\Channel\AbstractChannel;
 use PhpAmqpLib\Exception\AMQPProtocolConnectionException;
 use PhpAmqpLib\Exception\AMQPRuntimeException;
 use PhpAmqpLib\Exception\AMQPTimeoutException;

PhpAmqpLib/Helper/Protocol/Protocol091.php

Unused Use Statements +1 added lines, -1 removed lines

@@ -4,8 +4,8 @@
 
 namespace PhpAmqpLib\Helper\Protocol;
 
-use PhpAmqpLib\Wire\AMQPWriter;
 use PhpAmqpLib\Wire\AMQPReader;
+use PhpAmqpLib\Wire\AMQPWriter;
 
 class Protocol091
 {

Doc Comments +10 added lines, -10 removed lines

@@ -55,7 +55,7 @@ 
 
     /**
      * @param AMQPReader $reader
-     * @return array
+     * @return string[]
      */
     public static function connectionSecureOk(AMQPReader $reader)
     {
@@ -109,7 +109,7 @@ 
 
     /**
      * @param AMQPReader $reader
-     * @return array
+     * @return string[]
      */
     public static function connectionOpenOk(AMQPReader $reader)
     {
@@ -179,7 +179,7 @@ 
 
     /**
      * @param AMQPReader $reader
-     * @return array
+     * @return string[]
      */
     public static function channelOpenOk(AMQPReader $reader)
     {
@@ -201,7 +201,7 @@ 
 
     /**
      * @param AMQPReader $reader
-     * @return array
+     * @return boolean[]
      */
     public static function channelFlowOk(AMQPReader $reader)
     {
@@ -409,7 +409,7 @@ 
 
     /**
      * @param AMQPReader $reader
-     * @return array
+     * @return string[]
      */
     public static function queueDeclareOk(AMQPReader $reader)
     {
@@ -468,7 +468,7 @@ 
 
     /**
      * @param AMQPReader $reader
-     * @return array
+     * @return string[]
      */
     public static function queuePurgeOk(AMQPReader $reader)
     {
@@ -496,7 +496,7 @@ 
 
     /**
      * @param AMQPReader $reader
-     * @return array
+     * @return string[]
      */
     public static function queueDeleteOk(AMQPReader $reader)
     {
@@ -583,7 +583,7 @@ 
 
     /**
      * @param AMQPReader $reader
-     * @return array
+     * @return string[]
      */
     public static function basicConsumeOk(AMQPReader $reader)
     {
@@ -607,7 +607,7 @@ 
 
     /**
      * @param AMQPReader $reader
-     * @return array
+     * @return string[]
      */
     public static function basicCancelOk(AMQPReader $reader)
     {
@@ -702,7 +702,7 @@ 
 
     /**
      * @param AMQPReader $reader
-     * @return array
+     * @return string[]
      */
     public static function basicGetEmpty(AMQPReader $reader)
     {

PhpAmqpLib/Wire/AMQPReader.php

Doc Comments +1 added lines, -1 removed lines

@@ -521,7 +521,7 @@
     /**
      * Sets the timeout (second)
      *
-     * @param $timeout
+     * @param integer $timeout
      */
     public function setTimeout($timeout)
     {

PhpAmqpLib/Wire/AMQPWriter.php

Doc Comments +2 added lines, -2 removed lines

@@ -131,7 +131,7 @@ 
     /**
      * Write multiple bits as an octet
      *
-     * @param $bits
+     * @param boolean[] $bits
      * @return $this
      */
     public function write_bits($bits)
@@ -306,7 +306,7 @@ 
 
     /**
      * @param int $n
-     * @return array
+     * @return integer[]
      */
     private function splitIntoQuads($n)
     {

PhpAmqpLib/Wire/IO/StreamIO.php

Doc Comments +3 added lines, -3 removed lines

@@ -184,7 +184,7 @@ 
     /**
      * @param $len
      * @throws \PhpAmqpLib\Exception\AMQPIOException
-     * @return mixed|string
+     * @return string
      */
     public function read($len)
     {
@@ -239,7 +239,7 @@ 
     }
 
     /**
-     * @param $data
+     * @param string $data
      * @return mixed|void
      * @throws \PhpAmqpLib\Exception\AMQPRuntimeException
      * @throws \PhpAmqpLib\Exception\AMQPTimeoutException
@@ -374,7 +374,7 @@ 
     /**
      * @param $sec
      * @param $usec
-     * @return int|mixed
+     * @return integer
      */
     public function select($sec, $usec)
     {

PhpAmqpLib/Helper/Protocol/Protocol080.php

Unused Use Statements +1 added lines, -1 removed lines

@@ -4,8 +4,8 @@
 
 namespace PhpAmqpLib\Helper\Protocol;
 
-use PhpAmqpLib\Wire\AMQPWriter;
 use PhpAmqpLib\Wire\AMQPReader;
+use PhpAmqpLib\Wire\AMQPWriter;
 
 class Protocol091
 {

Doc Comments +18 added lines, -18 removed lines

@@ -55,7 +55,7 @@ 
 
     /**
      * @param AMQPReader $reader
-     * @return array
+     * @return string[]
      */
     public static function connectionSecureOk(AMQPReader $reader)
     {
@@ -109,7 +109,7 @@ 
 
     /**
      * @param AMQPReader $reader
-     * @return array
+     * @return string[]
      */
     public static function connectionOpenOk(AMQPReader $reader)
     {
@@ -192,7 +192,7 @@ 
 
     /**
      * @param AMQPReader $reader
-     * @return array
+     * @return boolean[]
      */
     public static function channelFlowOk(AMQPReader $reader)
     {
@@ -353,7 +353,7 @@ 
 
     /**
      * @param AMQPReader $reader
-     * @return array
+     * @return string[]
      */
     public static function queueDeclareOk(AMQPReader $reader)
     {
@@ -412,7 +412,7 @@ 
 
     /**
      * @param AMQPReader $reader
-     * @return array
+     * @return string[]
      */
     public static function queuePurgeOk(AMQPReader $reader)
     {
@@ -440,7 +440,7 @@ 
 
     /**
      * @param AMQPReader $reader
-     * @return array
+     * @return string[]
      */
     public static function queueDeleteOk(AMQPReader $reader)
     {
@@ -525,7 +525,7 @@ 
 
     /**
      * @param AMQPReader $reader
-     * @return array
+     * @return string[]
      */
     public static function basicConsumeOk(AMQPReader $reader)
     {
@@ -549,7 +549,7 @@ 
 
     /**
      * @param AMQPReader $reader
-     * @return array
+     * @return string[]
      */
     public static function basicCancelOk(AMQPReader $reader)
     {
@@ -644,7 +644,7 @@ 
 
     /**
      * @param AMQPReader $reader
-     * @return array
+     * @return string[]
      */
     public static function basicGetEmpty(AMQPReader $reader)
     {
@@ -758,7 +758,7 @@ 
 
     /**
      * @param AMQPReader $reader
-     * @return array
+     * @return string[]
      */
     public static function fileConsumeOk(AMQPReader $reader)
     {
@@ -782,7 +782,7 @@ 
 
     /**
      * @param AMQPReader $reader
-     * @return array
+     * @return string[]
      */
     public static function fileCancelOk(AMQPReader $reader)
     {
@@ -806,7 +806,7 @@ 
 
     /**
      * @param AMQPReader $reader
-     * @return array
+     * @return string[]
      */
     public static function fileOpenOk(AMQPReader $reader)
     {
@@ -957,7 +957,7 @@ 
 
     /**
      * @param AMQPReader $reader
-     * @return array
+     * @return string[]
      */
     public static function streamConsumeOk(AMQPReader $reader)
     {
@@ -981,7 +981,7 @@ 
 
     /**
      * @param AMQPReader $reader
-     * @return array
+     * @return string[]
      */
     public static function streamCancelOk(AMQPReader $reader)
     {
@@ -1175,7 +1175,7 @@ 
 
     /**
      * @param AMQPReader $reader
-     * @return array
+     * @return string[]
      */
     public static function testIntegerOk(AMQPReader $reader)
     {
@@ -1201,7 +1201,7 @@ 
 
     /**
      * @param AMQPReader $reader
-     * @return array
+     * @return string[]
      */
     public static function testStringOk(AMQPReader $reader)
     {
@@ -1227,7 +1227,7 @@ 
 
     /**
      * @param AMQPReader $reader
-     * @return array
+     * @return string[]
      */
     public static function testTableOk(AMQPReader $reader)
     {
@@ -1249,7 +1249,7 @@ 
 
     /**
      * @param AMQPReader $reader
-     * @return array
+     * @return string[]
      */
     public static function testContentOk(AMQPReader $reader)
     {