Skip to content

Commit c0a563f

Browse files
committed
- force int for xmessagettl to avoid {unacceptable_type,longstr} in some cases
1 parent 88bda43 commit c0a563f

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

src/Queue/AMQPQueue.php

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -284,7 +284,7 @@ public function declareDelayedQueue($destinationQueueName, $delay)
284284
'arguments' => new AMQPTable([
285285
'x-dead-letter-exchange' => '',
286286
'x-dead-letter-routing-key' => $destinationQueueName,
287-
'x-message-ttl' => $delay * 1000,
287+
'x-message-ttl' => intval($delay * 1000),
288288
]),
289289
]);
290290

0 commit comments

Comments
 (0)