How to Delete Messages from the Message Queue / Transport? (Doctrine) #60354

marvindinges · 2025-05-06T08:18:36Z

marvindinges
May 6, 2025

In my use case, I have some messages in the queue / transport with a DelayStamp, and I want to be able to delete one on request. I've tried to use the TransportInterface with no success.
My approach:

 #[Route('/api/delete/quick_note', name: 'api_delete_quick_note', methods: ['POST'], format: 'json')]
    public function deleteQuickNote(
        #[CurrentUser] ?User $user,
        #[MapRequestPayload] QuickNoteDto $dto,
        #[Autowire(service: 'messenger.transport.async')] TransportInterface $transport
    ): JsonResponse {
         /** @var DoctrineTransport $transport **/
        $transport->setup();
        $envelopes = $transport->get(); // $transport->all();

        foreach ($envelopes as $envelope) {
            $transportMessage = $envelope->getMessage();
            if (
                $transportMessage instanceof QuickNoteNotification
                && $transportMessage->getId() === $dto->Id
            ) {
                $transport->ack($envelope); // Remove
            } else {
                $transport->send($envelope); // Put it back in the queue
            }
        }

        return new JsonResponse(['message' => 'Quick note deleted successfully'], Response::HTTP_OK);
    }

But $transport->get() is always empty

Provide feedback

Saved searches

Use saved searches to filter your results more quickly

How to Delete Messages from the Message Queue / Transport? (Doctrine) #60354

{{title}}

Replies: 0 comments

Select a reply

How to Delete Messages from the Message Queue / Transport? (Doctrine) #60354

marvindinges May 6, 2025

Replies: 0 comments

marvindinges
May 6, 2025