Skip to content

Commit 11e4b3e

Browse files
committed
fix deprecated heartbeat check method
1 parent d08ee33 commit 11e4b3e

File tree

2 files changed

+2
-2
lines changed

2 files changed

+2
-2
lines changed

AmqpSubscriptionConsumer.php

+1-1
Original file line numberDiff line numberDiff line change
@@ -49,7 +49,7 @@ public function consume(int $timeout = 0): void
4949
$signalHandler->beforeSocket();
5050

5151
$heartbeatOnTick = function (AmqpContext $context) {
52-
$context->getLibChannel()->getConnection()->getIO()->check_heartbeat();
52+
$context->getLibChannel()->getConnection()->checkHeartBeat();
5353
};
5454

5555
$this->heartbeatOnTick && register_tick_function($heartbeatOnTick, $this->context);

composer.json

+1-1
Original file line numberDiff line numberDiff line change
@@ -7,7 +7,7 @@
77
"license": "MIT",
88
"require": {
99
"php": "^7.1.3",
10-
"php-amqplib/php-amqplib": "^2.8",
10+
"php-amqplib/php-amqplib": "^2.10",
1111
"queue-interop/amqp-interop": "^0.8",
1212
"queue-interop/queue-interop": "^0.7|^0.8",
1313
"enqueue/amqp-tools": "^0.9"

0 commit comments

Comments
 (0)