diff --git a/pkg/amqp-lib/AmqpSubscriptionConsumer.php b/pkg/amqp-lib/AmqpSubscriptionConsumer.php index a5917dbed..e70b61a24 100644 --- a/pkg/amqp-lib/AmqpSubscriptionConsumer.php +++ b/pkg/amqp-lib/AmqpSubscriptionConsumer.php @@ -49,7 +49,7 @@ public function consume(int $timeout = 0): void $signalHandler->beforeSocket(); $heartbeatOnTick = function (AmqpContext $context) { - $context->getLibChannel()->getConnection()->getIO()->check_heartbeat(); + $context->getLibChannel()->getConnection()->checkHeartBeat(); }; $this->heartbeatOnTick && register_tick_function($heartbeatOnTick, $this->context); diff --git a/pkg/amqp-lib/composer.json b/pkg/amqp-lib/composer.json index 100dc583b..f5d29ecf6 100644 --- a/pkg/amqp-lib/composer.json +++ b/pkg/amqp-lib/composer.json @@ -7,7 +7,7 @@ "license": "MIT", "require": { "php": "^7.1.3", - "php-amqplib/php-amqplib": "^2.8", + "php-amqplib/php-amqplib": "^2.10", "queue-interop/amqp-interop": "^0.8", "queue-interop/queue-interop": "^0.7|^0.8", "enqueue/amqp-tools": "^0.9"