У меня есть несколько подписок, которые прослушивают разные темы для сообщений, и некоторые из этих сообщений зависят друг от друга. Таким образом, одно сообщение для одной подписки «должно» прийти раньше других сообщений в другой подписке.
Я мог бы решить эту проблему путем временного хранения сообщений в базе данных, но я подумал, что если я получаю сообщение по одной подписке, а его коррелированные сообщения по другой подписке еще не поступили, я просто подождал бы 1 секунду и положил первые сообщения возвращаются по подписке, поэтому коррелированные сообщения получают еще некоторое время, чтобы прибыть первыми.
Легко, если бы это была Очередь, но теперь это подписка, и у этого клиента нет никаких методов "Отправить".
Я не хочу возвращать сообщения в разделы, так как другие подписчики могут не захотеть, чтобы эти сообщения снова.
Поскольку подписки в основном представляют собой очередь, это должно быть возможно, поэтому существует некоторый «базовый объект», который можно использовать для помещения сообщений непосредственно в очередь подписки.
С наилучшими пожеланиями
Магнус Рад