var redis = require('redis');
var EventEmitter = require('events').EventEmitter;

module.exports = function (port, host) {

	var pubClient = redis.createClient(port, host);
	var subClient = redis.createClient(port, host);

	var broker = new EventEmitter();

	subClient.on('message', broker.emit.bind(broker, 'message'));

	broker.subscribe = subClient.subscribe.bind(subClient);
	broker.unsubscribe = subClient.unsubscribe.bind(subClient);
	broker.publish = pubClient.publish.bind(pubClient);

	return broker;
};