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

Commit 08e6801

Browse files
committed
adding support for Laravel 5.2
1 parent e08a827 commit 08e6801

File tree

5 files changed

+16
-217
lines changed

5 files changed

+16
-217
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: 5 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -1,6 +1,6 @@
11
{
22
"name": "vladimir-yuldashev/laravel-queue-rabbitmq",
3-
"version": "5.1",
3+
"version": "5.2",
44
"description": "RabbitMQ driver for Laravel Queue",
55
"license": "MIT",
66
"authors": [
@@ -11,14 +11,14 @@
1111
],
1212
"require": {
1313
"php": ">=5.5.9",
14-
"illuminate/support": "5.1.*",
15-
"illuminate/queue": "5.1.*",
16-
"videlalvaro/php-amqplib": "2.5.*"
14+
"illuminate/support": "5.2.*",
15+
"illuminate/queue": "5.2.*",
16+
"videlalvaro/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)