koa_server.js

gistfile1.js

var koa = require('koa'),
    app = module.exports = koa(),
    route = require('koa-route');

// x-response-time
app.use(function *(next){
  var start = new Date;
  yield next;
  var ms = new Date - start;
  this.set('X-Response-Time', ms + 'ms');
});

// logger
app.use(function *(next){
  var start = new Date;
  yield next;
  var ms = new Date - start;
  console.log('%s - %s: %s ms', this.method, this.url, ms);
});

// response
app.use(route.get('/:queue', show));
app.use(route.post('/:queue', create));

function *show(queue) {
  this.body = 'Getting data from queue: ' + queue;
}

function *create(queue) {
  this.body = 'Posting data into queue: ' + queue;
}

app.use(function *() {
  this.body = 'Here goes the metadata...';
});

app.listen(3000);