Есть идеи, как создать параметризованный потоковый API?

Question

Я хочу создать параметризованный API-интерфейс для потоковой передачи, например http://dev.twitter.com/pages/streaming_api_methods#statuses-filter

Я вижу простой способ:

1. Создание канала для переадресации сообщений (например, статусы Twitter).
2. Каждый подключенный сокет подписывается на этот канал.
3. Внутри обратного вызова redis каждый сокет проверяет, соответствует ли текущее сообщение предоставленным параметрам (параметры могут быть установлены как отдельное сообщение сокета)

Чтовы думаете, ребята?

Answer 1

Возможно, вы захотите взглянуть на nats