search

phpinnacle / ridge

Pure asynchronous PHP implementation of the AMQP 0-9-1 protocol.
MIT License
50 stars 13 forks source link

Connection closed after 1 sesonds #32

Closed PNixx closed 2 years ago

PNixx commented 2 years ago

Version 1.3.0

Simple code:

\Amp\Loop::run(function() {
    $client = Client::create("amqp://guest:guest@localhost:5672/?timeout=5000");
    yield $client->connect();
    print_r('Connected: ' . $client->isConnected() . PHP_EOL);
    \Amp\Loop::repeat(1000, fn() => print_r('Connected: ' . $client->isConnected() . PHP_EOL));
});

And see in log:

Connected: 1
Connected: 1
Connected: 
Connected: 
Connected:

But I see active connection in rabbit console:

screenshot