test/hyperf
1
0
Fork 0
mirror of https://gitee.com/hyperf/hyperf.git synced 2024-11-30 02:37:58 +08:00
Code Issues Actions 16 Packages Projects Releases Wiki Activity

Fixed timeout when produce a amqp message.

Browse Source
This commit is contained in:
李铭昕 2019-07-24 17:16:20 +08:00
parent f476db3244
commit 92981372bd
1 changed files with 3 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

11
src/amqp/src/Connection.php
View File

@ -139,7 +139,7 @@ class Connection extends BaseConnection implements ConnectionInterface
$class = AMQPSwooleConnection::class;
}
$this->lastHeartbeatTime = 0;
$this->lastHeartbeatTime = microtime(true);
return new $class($this->config['host'] ?? 'localhost', $this->config['port'] ?? 5672, $this->config['user'] ?? 'guest', $this->config['password'] ?? 'guest', $this->config['vhost'] ?? '/', $this->params->isInsist(), $this->params->getLoginMethod(), $this->params->getLoginResponse(), $this->params->getLocale(), $this->params->getConnectionTimeout(), $this->params->getReadWriteTimeout(), $this->params->getContext(), $this->params->isKeepalive(), $this->params->getHeartbeat());
}
@ -149,13 +149,8 @@ class Connection extends BaseConnection implements ConnectionInterface
return false;
}
$lastHeartbeatTime = $this->lastHeartbeatTime;
$currentTime = microtime(true);
if ($lastHeartbeatTime && $lastHeartbeatTime > 0) {
if ($currentTime - $lastHeartbeatTime > $this->params->getHeartbeat()) {
return true;
}
if (microtime(true) - $this->lastHeartbeatTime > $this->params->getHeartbeat()) {
return true;
}
return false;