Merged 2.1 changes to master

Author: Naktibalda

src/Codeception/Module/AMQP.php

@@ -6,7 +6,7 @@
 use Codeception\TestInterface;
 use Exception;
 use PhpAmqpLib\Channel\AMQPChannel;
-use PhpAmqpLib\Connection\AMQPConnection;
+use PhpAmqpLib\Connection\AMQPStreamConnection;
 use PhpAmqpLib\Message\AMQPMessage;
 use PhpAmqpLib\Exception\AMQPProtocolChannelException;
 
@@ -50,7 +50,7 @@
  *
  * ## Public Properties
  *
- * * connection - AMQPConnection - current connection
+ * * connection - AMQPStreamConnection - current connection
  *
  * @since 1.1.2
  * @author [email protected]
@@ -68,7 +68,7 @@ class AMQP extends CodeceptionModule
     ];
 
     /**
-     * @var AMQPConnection
+     * @var AMQPStreamConnection
      */
     public $connection;
 
@@ -88,7 +88,7 @@ public function _initialize()
         $vhost = $this->config['vhost'];
 
         try {
-            $this->connection = new AMQPConnection($host, $port, $username, $password, $vhost);
+            $this->connection = new AMQPStreamConnection($host, $port, $username, $password, $vhost);
         } catch (Exception $e) {
             throw new ModuleException(__CLASS__, $e->getMessage() . ' while establishing connection to MQ server');
         }