diff --git a/lib/queue.js b/lib/queue.js
index 45a1535ecd8d91e5a685fd3bcb0a102bc4fe4a63..b1676e512ee3ccf2513f47e31f9708ed6d37a2f7 100644
--- a/lib/queue.js
+++ b/lib/queue.js
@@ -98,7 +98,7 @@ var Queue = function Queue(name, redisPort, redisHost, redisOptions){
   function createClient() {
     var client;
     if(_.isFunction(redisOptions.createClient)){
-      client = new redisOptions();
+      client = redisOptions.createClient();
     }else{
       client = new redis(redisPort, redisHost, redisOptions);
     }