Skip to content

Commit 2e99304

Browse files
committed
Fix acknowledgeAndPublish
1 parent 751d49f commit 2e99304

File tree

1 file changed

+5
-2
lines changed

1 file changed

+5
-2
lines changed

src/PubSubQueue.php

Lines changed: 5 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -198,13 +198,16 @@ public function acknowledge(Message $message, $queue = null)
198198
*/
199199
public function acknowledgeAndPublish(Message $message, $queue = null, $options = [], $delay = 0)
200200
{
201+
if (isset($options['attempts'])) {
202+
$options['attempts'] = (string) $options['attempts'];
203+
}
201204
$topic = $this->getTopic($this->getQueue($queue));
202-
$subscription = $topic->subscription($queue);
205+
$subscription = $topic->subscription($this->subscriber);
203206

204207
$subscription->acknowledge($message);
205208

206209
$options = array_merge([
207-
'available_at' => $this->availableAt($delay),
210+
'available_at' => (string) $this->availableAt($delay),
208211
], $options);
209212

210213
return $topic->publish([

0 commit comments

Comments
 (0)