который должен быть отправлен в будущем. Проверяю это так:
1. Слушаю ивент WorkerMessageReceivedEvent
2. Проверяю, если datetime объекта > currentTime
3. Если да (время ещё не наступило), то ставлю $event->shouldHandle(false);
Вроде как всё работает, но проблема в том, что даже если время наступило, то обработчик так и не обрабатывает этот Message, хотя он всё ещё висит в таблице (в качестве транспорта использую doctrine).
В чём проблема? Других идей не нашёл, как добавлять сообщения в будущем
Есть же штатный механизм отправки сообщений по вермени. https://symfony.com/doc/current/messenger.html#envelopes-stamps Или я не понимаю в чём проблема.
Хм, в примере, в DelayStamp нужно указывать время в миллисекундах. Если сообщение должно быть отправлено через 30 дней, там число страшное получится. Почему-то мне кажется, что это не самый правильный вариант
Потому что пугаешься легко
Обсуждают сегодня