Skip to content
This repository was archived by the owner on Sep 3, 2020. It is now read-only.

Commit a5f39b3

Browse files
Merge branch 'master' into toolstation
2 parents 9d6c2f2 + a404ea9 commit a5f39b3

File tree

5 files changed

+13
-214
lines changed

5 files changed

+13
-214
lines changed

LICENSE

Lines changed: 0 additions & 202 deletions
This file was deleted.

README.md

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -6,7 +6,7 @@ RabbitMQ Queue driver for Laravel
66

77
Require this package in your composer.json and run composer update (IMPORTANT! DO NOT USE "dev-master"):
88

9-
"vladimir-yuldashev/laravel-queue-rabbitmq": "5.1"
9+
"vladimir-yuldashev/laravel-queue-rabbitmq": "5.2"
1010

1111
After composer update is finished you need to add ServiceProvider to your `providers` array in `app.php`:
1212

@@ -69,5 +69,5 @@ Unit tests will be provided soon.
6969
You can contribute to this package by discovering bugs and opening issues. Enjoy!
7070

7171
####Supported versions of Laravel
72-
4.0, 4.1, 4.2, 5.0, 5.1
72+
4.0, 4.1, 4.2, 5.0, 5.1, 5.2
7373
The version is being matched by the release tag of this library.

composer.json

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -13,12 +13,12 @@
1313
"php": ">=5.5.9",
1414
"illuminate/support": "5.2.*",
1515
"illuminate/queue": "5.2.*",
16-
"videlalvaro/php-amqplib": "2.5.*"
16+
"php-amqplib/php-amqplib": "2.6.*"
1717
},
1818
"autoload": {
1919
"psr-0": {
2020
"VladimirYuldashev\\LaravelQueueRabbitMQ": "src/"
2121
}
2222
},
23-
"minimum-stability": "dev"
23+
"minimum-stability": "stable"
2424
}

src/VladimirYuldashev/LaravelQueueRabbitMQ/Queue/Connectors/RabbitMQConnector.php

Lines changed: 3 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -3,7 +3,7 @@
33
namespace VladimirYuldashev\LaravelQueueRabbitMQ\Queue\Connectors;
44

55
use Illuminate\Queue\Connectors\ConnectorInterface;
6-
use PhpAmqpLib\Connection\AMQPConnection;
6+
use PhpAmqpLib\Connection\AMQPStreamConnection;
77
use VladimirYuldashev\LaravelQueueRabbitMQ\Queue\RabbitMQQueue;
88

99
class RabbitMQConnector implements ConnectorInterface
@@ -19,7 +19,8 @@ class RabbitMQConnector implements ConnectorInterface
1919
public function connect(array $config)
2020
{
2121
// create connection with AMQP
22-
$connection = new AMQPConnection($config['host'], $config['port'], $config['login'], $config['password'], $config['vhost']);
22+
$connection = new AMQPStreamConnection($config['host'], $config['port'], $config['login'], $config['password'],
23+
$config['vhost']);
2324

2425
return new RabbitMQQueue(
2526
$connection,

src/VladimirYuldashev/LaravelQueueRabbitMQ/Queue/RabbitMQQueue.php

Lines changed: 6 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -6,7 +6,7 @@
66
use Illuminate\Contracts\Queue\Queue as QueueContract;
77
use Illuminate\Queue\Queue;
88
use PhpAmqpLib\Channel\AMQPChannel;
9-
use PhpAmqpLib\Connection\AMQPConnection;
9+
use PhpAmqpLib\Connection\AMQPStreamConnection;
1010
use PhpAmqpLib\Message\AMQPMessage;
1111
use PhpAmqpLib\Wire\AMQPTable;
1212
use VladimirYuldashev\LaravelQueueRabbitMQ\Queue\Jobs\RabbitMQJob;
@@ -24,11 +24,11 @@ class RabbitMQQueue extends Queue implements QueueContract
2424
protected $configQueue;
2525
protected $configExchange;
2626

27-
/**
28-
* @param AMQPConnection $amqpConnection
29-
* @param array $config
30-
*/
31-
public function __construct(AMQPConnection $amqpConnection, $config)
27+
/**
28+
* @param AMQPStreamConnection $amqpConnection
29+
* @param array $config
30+
*/
31+
public function __construct(AMQPStreamConnection $amqpConnection, $config)
3232
{
3333
$this->connection = $amqpConnection;
3434
$this->defaultQueue = $config['queue'];

0 commit comments

Comments
 (0)