Allow to requeue message in google pub/sub

php-enqueue · Apr 7, 2023 · e3b271d · e3b271d
1 parent 0c6ff18
commit e3b271d
Showing 1 changed file with 10 additions and 2 deletions.
diff --git a/pkg/gps/GpsConsumer.php b/pkg/gps/GpsConsumer.php
@@ -92,11 +92,19 @@ public function acknowledge(Message $message): void
  */
  public function reject(Message $message, bool $requeue = false): void
  {
- if (false == $message->getNativeMessage()) {
+ $nativeMessage = $message->getNativeMessage();
+
+ if (null === $nativeMessage) {
  throw new \LogicException('Native google pub/sub message required but it is empty');
  }
 
- $this->getSubscription()->acknowledge($message->getNativeMessage());
+ $subscription = $this->getSubscription();
+
+ if ($requeue) {
+ $subscription->modifyAckDeadline($nativeMessage, 0);
+ } else {
+ $subscription->acknowledge($nativeMessage);
+ }
  }
 
  private function getSubscription(): Subscription