From 98978446a343abe21a31ffad6048008d6beee6bb Mon Sep 17 00:00:00 2001
From: Hyungjin Kim <hyungjin.kim@dena.com>
Date: Wed, 19 Feb 2014 11:56:23 +0900
Subject: [PATCH 1/2] Supports options.db to select redis db

---
 devents.js | 8 +++++++-
 1 file changed, 7 insertions(+), 1 deletion(-)

diff --git a/devents.js b/devents.js
index 3706dcb..06286d5 100644
--- a/devents.js
+++ b/devents.js
@@ -25,11 +25,17 @@ function DistributedEventEmitter( options ) {
         self.sub.on( 'error', EmitError );
 
         self.pub.on( 'connect', function() {
+            if (opts.db) {
+                self.pub.select(opts.db);
+            }
             self.pubConnected = true; 
             events.EventEmitter.prototype.emit.apply( self, [ 'connect', 'pub', self.pub ] );
         });
         
         self.sub.on( 'connect', function() {
+            if (opts.db) {
+                self.sub.select(opts.db);
+            }
             self.sub.on( 'subscribe', function( channel, count ) {
                 self.subConnected = true;
                 events.EventEmitter.prototype.emit.apply( self, [ 'connect', 'sub', self.sub ] );
@@ -64,4 +70,4 @@ DistributedEventEmitter.prototype.emit = function() {
     }
 }
 
-module.exports.DistributedEventEmitter = DistributedEventEmitter;
\ No newline at end of file
+module.exports.DistributedEventEmitter = DistributedEventEmitter;

From 9ba8d68ca8d50ec4caded345038edc67733c6238 Mon Sep 17 00:00:00 2001
From: Hyungjin Kim <hyungjin.kim@dena.com>
Date: Thu, 20 Feb 2014 07:18:40 +0900
Subject: [PATCH 2/2] Correct code style

---
 devents.js | 10 ++++++----
 1 file changed, 6 insertions(+), 4 deletions(-)

diff --git a/devents.js b/devents.js
index 06286d5..02b9e0a 100644
--- a/devents.js
+++ b/devents.js
@@ -25,16 +25,18 @@ function DistributedEventEmitter( options ) {
         self.sub.on( 'error', EmitError );
 
         self.pub.on( 'connect', function() {
-            if (opts.db) {
-                self.pub.select(opts.db);
+            if ( opts.db )
+            {
+                self.pub.select( opts.db );
             }
             self.pubConnected = true; 
             events.EventEmitter.prototype.emit.apply( self, [ 'connect', 'pub', self.pub ] );
         });
         
         self.sub.on( 'connect', function() {
-            if (opts.db) {
-                self.sub.select(opts.db);
+            if ( opts.db )
+            {
+                self.sub.select( opts.db );
             }
             self.sub.on( 'subscribe', function( channel, count ) {
                 self.subConnected = true;