add vhost config refs #1

goffyara · Nov 1, 2017 · 200bfa9 · 200bfa9
1 parent f62cabb
commit 200bfa9
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/src/Amqp.php b/src/Amqp.php
@@ -11,6 +11,7 @@ class Amqp extends Component
     public $port;
     public $user;
     public $password;
+    public $vhost = '/';
 
     private $_channel;
     private $_connection;
@@ -25,7 +26,8 @@ public function getConnection() {
             $this->host,
             $this->port,
             $this->user,
-            $this->password
+            $this->password,
+            $this->vhost
         );
 
         return $this->_connection;