Merge pull request php-amqplib#172 from fprochazka/patch-5

Declare missing properties

Author: videlalvaro

PhpAmqpLib/Channel/AMQPChannel.php

@@ -18,27 +18,32 @@ class AMQPChannel extends AbstractChannel
      */
     public $callbacks = array();
 
+    /**
+     * Whether or not the channel has been "opened" or not
+     *
+     * @var bool
+     */
+    protected $is_open = false;
+
     /**
      * @var int
      */
-    private $next_delivery_tag = 0;
+    protected $default_ticket;
 
     /**
-     * @var Callable
+     * @var bool
      */
-    private $ack_handler = null;
+    protected $active;
 
     /**
-     * @var Callable
+     * @var array
      */
-    private $nack_handler = null;
+    protected $alerts;
 
     /**
-     * If the channel is in confirm_publish mode this array will store all published messages
-     * until they get ack'ed or nack'ed
-     * @var AMQPMessage[]
+     * @var bool
      */
-    private $published_messages = array();
+    protected $auto_decode;
 
     /**
      * These parameters will be passed to function in case of basic_return:
@@ -60,6 +65,29 @@ class AMQPChannel extends AbstractChannel
      */
     protected $batch_messages = array();
 
+    /**
+     * If the channel is in confirm_publish mode this array will store all published messages
+     * until they get ack'ed or nack'ed
+     *
+     * @var AMQPMessage[]
+     */
+    private $published_messages = array();
+
+    /**
+     * @var int
+     */
+    private $next_delivery_tag = 0;
+
+    /**
+     * @var callable
+     */
+    private $ack_handler = null;
+
+    /**
+     * @var callable
+     */
+    private $nack_handler = null;
+
     /**
      * Circular buffer to speed up both basic_publish() and publish_batch().
      * Max size limited by $publish_cache_max_size.
@@ -75,12 +103,6 @@ class AMQPChannel extends AbstractChannel
      */
     private $publish_cache_max_size;
 
-    /**
-     * Whether or not the channel has been "opened" or not
-     * @var bool
-     */
-    protected $is_open = false;
-
 
     public function __construct($connection, $channel_id = null, $auto_decode = true)
     {

PhpAmqpLib/Channel/AbstractChannel.php

@@ -20,6 +20,29 @@ class AbstractChannel
 
     public static $PROTOCOL_CONSTANTS_CLASS;
 
+    /**
+     * @var array
+     */
+    protected $frame_queue;
+
+    /**
+     * @var array
+     */
+    protected $method_queue;
+
+    /**
+     * @var bool
+     */
+    protected $auto_decode;
+
+    /**
+     * @var string
+     */
+    protected $amqp_protocol_header;
+
+    /**
+     * @var bool
+     */
     protected $debug;
 
     /**

PhpAmqpLib/Connection/AbstractConnection.php

@@ -31,43 +31,80 @@ class AbstractConnection extends AbstractChannel
         )
     );
 
-    public $version_major;
+    /**
+     * @var AMQPChannel[]
+     */
+    public $channels = array();
 
-    public $version_minor;
+    /**
+     * @var int
+     */
+    protected $version_major;
+
+    /**
+     * @var int
+     */
+    protected $version_minor;
 
-    public $server_properties;
+    /**
+     * @var array
+     */
+    protected $server_properties;
 
-    public $heartbeat;
+    /**
+     * @var string
+     */
+    protected $heartbeat;
 
     /**
      * @var array
      */
-    public $mechanisms;
+    protected $mechanisms;
 
     /**
      * @var array
      */
-    public $locales;
+    protected $locales;
 
     /**
      * @var bool
      */
-    public $wait_tune_ok;
+    protected $wait_tune_ok;
 
     /**
      * @var string
      */
-    public $known_hosts;
+    protected $known_hosts;
 
     /**
      * @var AMQPReader
      */
-    public $input;
+    protected $input;
 
     /**
-     * @var AMQPChannel[]
+     * @var string
      */
-    public $channels = array();
+    protected $vhost;
+
+    /**
+     * @var bool
+     */
+    protected $insist;
+
+    /**
+     * @var string
+     */
+    protected $login_method;
+
+    /**
+     * @var AMQPWriter
+     */
+    protected $login_response;
+
+    /**
+     * @var string
+     */
+    protected $locale;
 
     /**
      * @var SocketIO
@@ -115,14 +152,14 @@ class AbstractConnection extends AbstractChannel
     /**
      * Handles connection blocking from the server
      *
-     * @var Callable
+     * @var callable
      */
     private $connection_block_handler = null;
 
     /**
      * Handles connection unblocking from the server
      *
-     * @var Callable
+     * @var callable
      */
     private $connection_unblock_handler = null;
 

PhpAmqpLib/Message/AMQPMessage.php

@@ -10,8 +10,19 @@
 class AMQPMessage extends GenericContent
 {
 
+    /**
+     * @var string
+     */
     public $body;
 
+    /**
+     * @var string
+     */
+    public $content_encoding;
+
+    /**
+     * @var array
+     */
     protected static $PROPERTIES = array(
         "content_type" => "shortstr",
         "content_encoding" => "shortstr",

PhpAmqpLib/Wire/AMQPDecimal.php

@@ -18,6 +18,18 @@
 class AMQPDecimal
 {
 
+    /**
+     * @var int
+     */
+    protected $n;
+
+    /**
+     * @var int
+     */
+    protected $e;
+
+
+
     public function __construct($n, $e)
     {
         if ($e < 0) {

PhpAmqpLib/Wire/AMQPReader.php

@@ -27,21 +27,45 @@ class AMQPReader
     const LONGLONG = 8;
     const TIMESTAMP = 8;
 
+    /**
+     * @var string
+     */
     protected $str;
 
+    /**
+     * @var int
+     */
     protected $str_length;
 
+    /**
+     * @var int
+     */
     protected $offset;
 
+    /**
+     * @var int
+     */
     protected $bitcount;
 
+    /**
+     * @var bool
+     */
     protected $is64bits;
 
+    /**
+     * @var int
+     */
     protected $timeout;
 
+    /**
+     * @var int
+     */
     protected $bits;
 
-    protected $io = null;
+    /**
+     * @var IO\AbstractIO
+     */
+    protected $io;
 
 
 

PhpAmqpLib/Wire/AMQPWriter.php

@@ -8,6 +8,23 @@
 class AMQPWriter
 {
 
+    /**
+     * @var string
+     */
+    protected $out;
+
+    /**
+     * @var array
+     */
+    protected $bits;
+
+    /**
+     * @var int
+     */
+    protected $bitcount;
+
+
+
     public function __construct()
     {
         $this->out = "";

PhpAmqpLib/Wire/GenericContent.php

@@ -16,6 +16,11 @@ abstract class GenericContent
      */
     public $delivery_info = array();
 
+    /**
+     * @var array
+     */
+    protected $prop_types;
+
     /**
      * @var array
      */

PhpAmqpLib/Wire/IO/SocketIO.php

@@ -8,10 +8,25 @@
 class SocketIO extends AbstractIO
 {
 
+    /**
+     * @var string
+     */
+    protected $host;
+
+    /**
+     * @var int
+     */
+    protected $port;
+
+    /**
+     * @var int
+     */
+    protected $timeout;
+
     /**
      * @var resource
      */
-    private $sock = null;
+    private $sock;