Add $seconds to keepalive methods

valtzu · valtzu · commit cda6f72060e6 · 2024-10-13T15:36:15.000+03:00
diff --git a/Transport/BeanstalkdReceiver.php b/Transport/BeanstalkdReceiver.php
@@ -65,7 +65,7 @@ public function reject(Envelope $envelope): void
         $this->connection->reject($this->findBeanstalkdReceivedStamp($envelope)->getId());
     }
 
-    public function keepalive(Envelope $envelope): void
+    public function keepalive(Envelope $envelope, ?int $seconds = null): void
     {
         $this->connection->keepalive($this->findBeanstalkdReceivedStamp($envelope)->getId());
     }
diff --git a/Transport/BeanstalkdTransport.php b/Transport/BeanstalkdTransport.php
@@ -49,9 +49,9 @@ public function reject(Envelope $envelope): void
         $this->getReceiver()->reject($envelope);
     }
 
-    public function keepalive(Envelope $envelope): void
+    public function keepalive(Envelope $envelope, ?int $seconds = null): void
     {
-        $this->getReceiver()->keepalive($envelope);
+        $this->getReceiver()->keepalive($envelope, $seconds);
     }
 
     public function getMessageCount(): int

Original file line number	Diff line number	Diff line change
`@@ -65,7 +65,7 @@ public function reject(Envelope $envelope): void`
`65`	`65`	`$this->connection->reject($this->findBeanstalkdReceivedStamp($envelope)->getId());`
`66`	`66`	`}`
`67`	`67`
`68`		`- public function keepalive(Envelope $envelope): void`
	`68`	`+ public function keepalive(Envelope $envelope, ?int $seconds = null): void`
`69`	`69`	`{`
`70`	`70`	`$this->connection->keepalive($this->findBeanstalkdReceivedStamp($envelope)->getId());`
`71`	`71`	`}`
Original file line number	Diff line number	Diff line change
`@@ -49,9 +49,9 @@ public function reject(Envelope $envelope): void`
`49`	`49`	`$this->getReceiver()->reject($envelope);`
`50`	`50`	`}`
`51`	`51`
`52`		`- public function keepalive(Envelope $envelope): void`
	`52`	`+ public function keepalive(Envelope $envelope, ?int $seconds = null): void`
`53`	`53`	`{`
`54`		`- $this->getReceiver()->keepalive($envelope);`
	`54`	`+ $this->getReceiver()->keepalive($envelope, $seconds);`
`55`	`55`	`}`
`56`	`56`
`57`	`57`	`public function getMessageCount(): int`