Skip to content

Commit bde92bc

Browse files
authored
Merge pull request php-amqplib#753 from kozlice/fix-752
Fix AMQPTimeoutException handling
2 parents 0798440 + 7a5f574 commit bde92bc

File tree

1 file changed

+3
-1
lines changed

1 file changed

+3
-1
lines changed

PhpAmqpLib/Connection/AbstractConnection.php

Lines changed: 3 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -576,7 +576,9 @@ protected function wait_frame($timeout = 0)
576576
$ch = $this->wait_frame_reader->read_octet();
577577

578578
} catch (AMQPTimeoutException $e) {
579-
$this->input->setTimeout($currentTimeout);
579+
if ($this->input) {
580+
$this->input->setTimeout($currentTimeout);
581+
}
580582
throw $e;
581583
} catch (AMQPNoDataException $e) {
582584
if ($this->input) {

0 commit comments

Comments
 (0)