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:
- Create redis channel for messages (like twitter statuses).
- Each connected socket subscribes on this channel.
- 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