Merge pull request #42 from uConnect/fix/rabbitmq-vhost

Adds support for RabbitMQ vhost
10up · Nov 1, 2018 · 4b4e21a · 4b4e21a
2 parents 24ac4e0 + 8d53b9e
commit 4b4e21a
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/includes/WpMinions/RabbitMQ/Connection.php b/includes/WpMinions/RabbitMQ/Connection.php
@@ -24,9 +24,10 @@ public function __construct() {
 				'port'     => 5672,
 				'username' => 'guest',
 				'password' => 'guest',
+				'vhost'    => '/',
 			) );
 
-			$this->connection = new \PhpAmqpLib\Connection\AMQPStreamConnection( $rabbitmq_server['host'], $rabbitmq_server['port'], $rabbitmq_server['username'], $rabbitmq_server['password'] );
+			$this->connection = new \PhpAmqpLib\Connection\AMQPStreamConnection( $rabbitmq_server['host'], $rabbitmq_server['port'], $rabbitmq_server['username'], $rabbitmq_server['password'], $rabbitmq_server['vhost'] );
 			$this->channel    = $this->connection->channel();
 
 			$rabbitmq_declare_passive_filter    = apply_filters( 'wp_minion_rabbitmq_declare_passive_filter', false );