Producer keepalive must be without timeout
This commit is contained in:
@@ -60,7 +60,7 @@ final class NsqTransport implements TransportInterface
|
|||||||
public function get(): iterable
|
public function get(): iterable
|
||||||
{
|
{
|
||||||
try {
|
try {
|
||||||
$this->producer->receive(); // keepalive, handle heartbeat messages
|
$this->producer->receive(0); // keepalive, handle heartbeat messages
|
||||||
} catch (Throwable $e) {
|
} catch (Throwable $e) {
|
||||||
$this->logger->error('Producer keepalive failed.', ['exception' => $e]);
|
$this->logger->error('Producer keepalive failed.', ['exception' => $e]);
|
||||||
}
|
}
|
||||||
|
Reference in New Issue
Block a user