Merge pull request #2 from answear/update-connection-last-activity-time

Update Connection::lastActivityTime by reflection
answear · Jun 7, 2023 · 1ca6cda · 1ca6cda
2 parents 16c0d5a + f7e5ade
commit 1ca6cda
Showing 1 changed file with 7 additions and 0 deletions.
diff --git a/src/Transport/AmqpTransport.php b/src/Transport/AmqpTransport.php
@@ -38,6 +38,13 @@ public function getHeartbeat(): int
     public function sendHeartbeat(): void
     {
         try {
+            if (\property_exists($this->connection, 'lastActivityTime')) {
+                $reflection = new \ReflectionClass($this->connection);
+                $property = $reflection->getProperty('lastActivityTime');
+                $property->setAccessible(true);
+                $property->setValue($this->connection, time());
+            }
+
             $this->getMessageCount();
         } catch (\Throwable $throwable) {
             if ($throwable instanceof TransportException || $throwable->getPrevious() instanceof TransportException) {