gistfile1.js

docs.forEach(function(doc) {
  if(doc != null) {
    var msg = doc['project_id'] + '. ' + doc['created_at'] + '. ' + doc['message'];
    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);
        }
      });
    });
  }
});