benchmark/suites/transporters.js
function createBrokers(transporter) {
	let b1 = new ServiceBroker({
		transporter,
		//requestTimeout: 0,
		logger: false,
		//logLevel: "debug",
		nodeID: "node-1"
	});

	let b2 = new ServiceBroker({
		transporter,
		//requestTimeout: 0,
		logger: false,
		//logLevel: "debug",
		nodeID: "node-2"
	});

	b2.createService({
		name: "echo",
		actions: {
			reply(ctx) {
				return ctx.params;
			}
		}
	});

	return Promise.all([
		b1.start(),
		b2.start()
	]).then(() => [b1, b2]);
}
function createBrokers(transporter) {
	let b1 = new ServiceBroker({
		transporter,
		//requestTimeout: 0,
		logger: false,
		//logLevel: "debug",
		nodeID: "node-1"
	});

	let b2 = new ServiceBroker({
		transporter,
		//requestTimeout: 0,
		logger: false,
		//logLevel: "debug",
		nodeID: "node-2"
	});

	b2.createService({
		name: "echo",
		actions: {
			reply(ctx) {
				return ctx.params;
			}
		}
	});

	return Promise.all([
		b1.start(),
		b2.start()
	]).then(() => [b1, b2]);
}
function createBrokers ( transporter ) { let b1 = new ServiceBroker ( { transporter , //requestTimeout: 0, logger : false , //logLevel: "debug", nodeID : "node-1" } ) ; let b2 = new ServiceBroker ( { transporter , //requestTimeout: 0, logger : false , //logLevel: "debug", nodeID : "node-2" } ) ; b2 . createService ( { name : "echo" , actions : { reply ( ctx ) { return ctx . params ; } } } ) ; return Promise . all ( [ b1 . start ( ) , b2 . start ( ) ] ) . then ( ( ) => [ b1 , b2 ] ) ; }
, "150", "1k", "10k", "50k", "100k", "1M"];
150 1k 10k 50k 100k 1M ] ;