Skip to content

Commit

Permalink
feat(benchmarks): add incredibly simple baseline benchmark tool
Browse files Browse the repository at this point in the history
  • Loading branch information
mbroadst committed Nov 5, 2015
1 parent 8b6af98 commit 7dbee49
Showing 1 changed file with 32 additions and 0 deletions.
32 changes: 32 additions & 0 deletions test/benchmarks/simple.js
Original file line number Diff line number Diff line change
@@ -0,0 +1,32 @@
'use strict';
var AMQPClient = require('../../lib').Client;

var client = new AMQPClient(),
messageCount = parseInt(process.argv[2]) || 10,
server = process.env.SERVER || 'localhost',
receivedCount = 0,
start, finish;

client.connect('amqp://' + server)
.then(function() {
return Promise.all([
client.createReceiver('amq.topic'),
client.createSender('amq.topic')
]);
})
.spread(function(receiver, sender) {
receiver.on('message', function(message) {
receivedCount++;
if (receivedCount === messageCount) {
finish = new Date();
console.log('=> sent ' + messageCount + ' messages in ' + (finish.getTime() - start.getTime()) + 'ms');
process.exit(0);
}
});

start = new Date();
var promises = [];
for (var i = 0; i < messageCount; i++)
promises.push(sender.send('test'));
return Promise.all(promises);
});

0 comments on commit 7dbee49

Please sign in to comment.