diff --git a/messenger/custom-transport.rst b/messenger/custom-transport.rst index f4f6c6ee535..045f8ffa389 100644 --- a/messenger/custom-transport.rst +++ b/messenger/custom-transport.rst @@ -61,7 +61,7 @@ Here is a simplified example of a database transport:: $row = $this->db->createQuery( 'SELECT * FROM my_queue - WHERE (delivered_at IS NULL OR delivered_at < :redeliver_timeout') + WHERE (delivered_at IS NULL OR delivered_at < :redeliver_timeout) AND handled = FALSE' ) ->setParameter('redeliver_timeout', new DateTimeImmutable('-5minutes'))