Как реализовать решение для очереди сообщений

У меня есть сценарий, в котором нужно поставить в очередь около 10 различных сообщений, а затем исключить из очереди / обработать. Одному подписчику понадобятся все 10 сообщений, а другому - только 8 из 10 сообщений. Я пытаюсь понять, как лучше всего настроить этот тип архитектуры. Создаете ли вы очередь для каждого типа сообщений, чтобы подписчики могли просто подписаться на соответствующие очереди, или вы сбрасываете их все в одну и ту же очередь и игнорируете сообщения, не относящиеся к этому подписчику? Я хочу обеспечить гибкость / масштабируемость решения и т. Д.

Процесс:

1. 10 различных XML-сообщений будут помещены в очередь на сервер IBM WebSphere MQ.
2. Мы будем использовать .Net (скорее всего, WCF, поскольку в WebSphere MQ 7.1 добавлена ​​поддержка WCF)
3. Мы удалим сообщения из очереди и загрузим их в другую внутреннюю базу данных (скорее всего, SQL Server).
4. Решение необходимо хорошо масштабировать, потому что мы будем обрабатывать очень большое количество сообщений, и оно может расти (вероятно, 40-50 000 в час). По крайней мере, для нас крупная сумма.

Как всегда высоко ценю информацию.

- S