Any ideas how to create parameterised streaming api?

I want to create parameterised streaming api like http://dev.twitter.com/pages/streaming_api_methods#statuses-filter

The straightforward way I see is following:

1. Create redis channel for messages (like twitter statuses).
2. Each connected socket subscribes on this 开发者_Python百科channel.
3. Inside redis callback each sockets check if current message fits supplied parameters (parameters could be set as separate socket message)

What you think guys?

---

You might want to look at nats