nsq/nsqphp
1
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

Expect heartbeat in checkIsOk

Browse Source
This commit is contained in:
Konstantin Grachev
2021-01-31 18:11:24 +03:00
parent 72dca5c73b
commit a66f622cf6
1 changed files with 6 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
src/Connection.php
View File

@@ -164,6 +164,12 @@ abstract class Connection
{ {
$response = $this->readResponse(); $response = $this->readResponse();
if ($response->isHeartBeat()) {
$this->command('NOP');
$response = $this->readResponse();
}
if (!$response->isOk()) { if (!$response->isOk()) {
throw new BadResponse($response); throw new BadResponse($response);
} }