Skip to content

Commit 81460cc

Browse files
committed
require amqp interop 0.7 ver
1 parent 69634d7 commit 81460cc

File tree

6 files changed

+14
-13
lines changed

6 files changed

+14
-13
lines changed

composer.json

+1-1
Original file line numberDiff line numberDiff line change
@@ -27,7 +27,7 @@
2727
"enqueue/test": "*@dev",
2828
"enqueue/async-event-dispatcher": "*@dev",
2929
"queue-interop/queue-interop": "^0.6@dev",
30-
"queue-interop/amqp-interop": "^0.6@dev",
30+
"queue-interop/amqp-interop": "^0.7@dev",
3131
"queue-interop/queue-spec": "^0.5@dev",
3232

3333
"phpunit/phpunit": "^5",

pkg/amqp-bunny/composer.json

+1-1
Original file line numberDiff line numberDiff line change
@@ -7,7 +7,7 @@
77
"require": {
88
"php": ">=5.6",
99

10-
"queue-interop/amqp-interop": "^0.6@dev",
10+
"queue-interop/amqp-interop": "^0.7@dev",
1111
"bunny/bunny": "^0.2.4",
1212
"enqueue/amqp-tools": "^0.8@dev"
1313
},

pkg/amqp-ext/AmqpContext.php

+9-8
Original file line numberDiff line numberDiff line change
@@ -327,14 +327,15 @@ public function unsubscribe(InteropAmqpConsumer $consumer)
327327
return;
328328
}
329329

330-
$consumerTag = $consumer->getConsumerTag();
331-
$consumer->setConsumerTag(null);
332-
333-
$extQueue = new \AMQPQueue($this->getExtChannel());
334-
$extQueue->setName($consumer->getQueue()->getQueueName());
335-
336-
$extQueue->cancel($consumerTag);
337-
unset($this->subscribers[$consumerTag]);
330+
// seg fault
331+
// $consumerTag = $consumer->getConsumerTag();
332+
// $consumer->setConsumerTag(null);
333+
//
334+
// $extQueue = new \AMQPQueue($this->getExtChannel());
335+
// $extQueue->setName($consumer->getQueue()->getQueueName());
336+
//
337+
// $extQueue->cancel($consumerTag);
338+
// unset($this->subscribers[$consumerTag]);
338339
}
339340

340341
/**

pkg/amqp-ext/composer.json

+1-1
Original file line numberDiff line numberDiff line change
@@ -8,7 +8,7 @@
88
"php": ">=5.6",
99
"ext-amqp": "^1.6",
1010

11-
"queue-interop/amqp-interop": "^0.6@dev",
11+
"queue-interop/amqp-interop": "^0.7@dev",
1212
"enqueue/amqp-tools": "^0.8@dev"
1313
},
1414
"require-dev": {

pkg/amqp-lib/composer.json

+1-1
Original file line numberDiff line numberDiff line change
@@ -8,7 +8,7 @@
88
"php": ">=5.6",
99
"php-amqplib/php-amqplib": "^2.7@dev",
1010
"queue-interop/queue-interop": "^0.6@dev",
11-
"queue-interop/amqp-interop": "^0.6@dev",
11+
"queue-interop/amqp-interop": "^0.7@dev",
1212
"enqueue/amqp-tools": "^0.8@dev"
1313
},
1414
"require-dev": {

pkg/amqp-tools/composer.json

+1-1
Original file line numberDiff line numberDiff line change
@@ -7,7 +7,7 @@
77
"require": {
88
"php": ">=5.6",
99
"queue-interop/queue-interop": "^0.6@dev",
10-
"queue-interop/amqp-interop": "^0.6@dev"
10+
"queue-interop/amqp-interop": "^0.7@dev"
1111
},
1212
"require-dev": {
1313
"phpunit/phpunit": "~5.4.0",

0 commit comments

Comments
 (0)