дело в том, что до того как старые будут затёрты, все новые сообщения в очереди должны были быть прочитаны всеми процессами, для этого им циклически передавалось управление.
Следовательно и очередь должны быть достаточно длинной, или иметь динамический размер.

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