Skip to content

Commit f6f58e7

Browse files
committed
reconnect after timeout
1 parent 9e0305a commit f6f58e7

1 file changed

Lines changed: 1 addition & 0 deletions

File tree

src/Kdyby/RabbitMq/Consumer.php

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -112,6 +112,7 @@ public function consume(int $msgAmount): void
112112
$this->logger->debug('Consumer idle timeout reached.', ['rabbitmq_consumer' => $this->exchangeOptions['name']]);
113113

114114
$this->getChannel()->getConnection()?->checkHeartBeat();
115+
$this->getChannel()->getConnection()?->reconnect();
115116
}
116117
}
117118

0 commit comments

Comments
 (0)