index.js

var Router = require('./router');
var ns = require('./namespace-module');

var router = new Router();


router.initialize();
var NUM_TESTS = 10;

var spawnAsync = function (i) {

    var req = {
        url: '/page/'+i,
        method: 'get',
        someId: Math.floor(Math.random() * Date.now()),
        body: '',
        headers: {}
    };

    ns.set('req', req);
    ns.set('id', req.someId);
    req.headers['content-type'] = 'text/html';
    var dispatchBound = router.dispatch.bind(router, req);
    process.nextTick(dispatchBound);
};


router.on('routeMatched', function () {

    var id = ns.get('id');
    var req = ns.get('req') || {};
    console.log('routeMatched listener: ',req.someId);

});


for (var i = 0; i < NUM_TESTS; i++) {
    var saBound = spawnAsync.bind(null,i);
    ns.run(saBound);
    // saBound();
};

namespace-module.js

var cls = require('continuation-local-storage');

var ns = cls.createNamespace('testing');
 
module.exports = ns;

package.json

{
  "name": "clsbughunt",
  "dependencies": {
    "continuation-local-storage": "~2.1.1",
    "director": "~1.2.0"
  }
}

router.js

var director = require('director');
var events = require('events');
var ns = require('./namespace-module');



var Router = function(){
    var emitter = new events.EventEmitter();
    var router = new director.http.Router();

    var createHandler = function (){
        return function(){
            console.log('handler: ',ns.get('id')); // this is ok
            emitter.emit('routeMatched', ns.get('id')); // but the listener for this event is not
        }
    }

    var ret = {
        _createHandler: createHandler,
        initialize: function(routes){
            router.on('get','/page/:id', ret._createHandler(/* route, routeFunction */));  
        },
        on: emitter.on.bind(emitter),
        once: emitter.once.bind(emitter),
        dispatch: function(req,res,next){
            console.log('in dispatch: ', ns.get('id'));
            router.dispatch(req,res,function(err){
                console.log(err);
            });
        }
    }

    return ret;

}

module.exports = Router;