diff --git a/celery.js b/celery.js
index 9a8ac4e..edd4173 100644
--- a/celery.js
+++ b/celery.js
@@ -130,7 +130,7 @@ function RedisBackend(conf) {
         self.disconnect = function () {};
     } else {
         self.redis = redis.createClient(conf.RESULT_BACKEND_OPTIONS);
-        self.redis_ex = self.redis.duplicate();
+        self.redis_ex = redis.createClient(conf.RESULT_BACKEND_OPTIONS);
 
         self.disconnect = function() {
             self.redis_ex.quit();