Какой шаблон проектирования следует применять, когда я получаю сообщение, прежде чем я его на самом деле слушаю

Я разработал своего рода шаблон проектирования «Публикация / подписка наблюдателя / слушателя», в котором моя бизнес-система подписывалась на прослушивание одного типа сообщения A, а затем отписывалась, чтобы подписаться на прослушивание другого типа сообщения B.

Проблема в том, что я быстро и быстро открываю сообщения A и B один за другим, настолько быстро, что моя система еще не подписалась на прослушивание сообщений B, когда сообщение B уже получено: следствие этого, с моей текущей системой мой слушатель никогда не будет уведомление.

Я думал об использовании очереди для хранения всех входящих сообщений и их использования после уведомления слушателей.

Но мне было интересно, есть ли общие реализации для такой проблемы.