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?