Как реализовать легкий сервис pub-sub в App Engine?

Во время презентации Google I / O 2009 «Автономная обработка в App Engine: взгляд в будущее» ( видео , слайды ) , Бретт Слаткин представляет службу очереди задач.

Он заявляет, что

Pub-sub системы максимизируют транзакции, разъединение:

• Большое количество небольших транзакций в секунду
• Разветвление «один ко многим» с изменением получателей
• Гарантированное упорядочивание, фильтрация, двухфазная фиксация

И особо подчеркивает

. Наш новый API реализует организацию очереди, а не pub-sub

. Меня интересует только подмножество этих функций:

• Разветвление «один ко многим» с изменение выбранных / фиксированных внутренних обработчиков приемников
• Гарантированное упорядочивание , фильтрация, двухфазная фиксация

Целевая цель - упростить публикацию уведомлений / сообщений между различными модулями одного и того же веб-приложения . Примеры сценариев использования:

• Уведомление платежного модуля о поступлении счетов.
• Предоставление пользователю возможности отслеживать изменения конкретного объекта домена, за которым он решил следить / пометить.

Каким будет правильный способ реализовать их поверх службы очереди задач?