gistfile1.js

for(i in docs) {
  var doc = docs[i];
  if(doc != null) {
    var msg = doc['project_id'] + '. ' + doc['created_at'] + '. ' + doc['message'];
    sys.puts("I'll send " + msg);
    redis_client.smembers("conn:project:" + doc['project_id'], function(err, client_ids) {
      client_ids.forEach(function(client_id, i) {
        client = socketio.clients[client_id];
        if(typeof client != 'undefined') {
          client.send(msg);
        }
      });
    });
  }
}