migrate from pecl extension to php amqp lib

vyuldashev · vyuldashev · commit ee1e74ab9d11 · 2015-02-26T17:57:02.000+03:00
diff --git a/src/FintechFab/LaravelQueueRabbitMQ/Queue/Connectors/RabbitMQConnector.php b/src/FintechFab/LaravelQueueRabbitMQ/Queue/Connectors/RabbitMQConnector.php
@@ -17,7 +17,7 @@ class RabbitMQConnector implements ConnectorInterface
 	public function connect(array $config)
 	{
 		// create connection with AMQP
-		$connection = new AMQPConnection($config['host'], $config['port'], $config['login'], $config['password']);
+		$connection = new AMQPConnection($config['host'], $config['port'], $config['login'], $config['password'], $config['vhost']);
 
 		return new RabbitMQQueue(
 			$connection,
diff --git a/src/examples/queue.php b/src/examples/queue.php
@@ -15,9 +15,9 @@
 			'driver'   => 'rabbitmq',
 
 			'host'     => '',
-			'port'     => '',
+			'port'  => 5672,
 
-			'vhost'    => '',
+			'vhost' => '/',
 			'login'    => '',
 			'password' => '',
 

Original file line number	Diff line number	Diff line change
`@@ -17,7 +17,7 @@ class RabbitMQConnector implements ConnectorInterface`
`17`	`17`	`public function connect(array $config)`
`18`	`18`	`{`
`19`	`19`	`// create connection with AMQP`
`20`		`- $connection = new AMQPConnection($config['host'], $config['port'], $config['login'], $config['password']);`
	`20`	`+ $connection = new AMQPConnection($config['host'], $config['port'], $config['login'], $config['password'], $config['vhost']);`
`21`	`21`
`22`	`22`	`return new RabbitMQQueue(`
`23`	`23`	`$connection,`