JavaScriptExpert
diff --git a/‎lib/kue.js
Lines changed: 7 additions & 5 deletions b/‎lib/kue.js
Lines changed: 7 additions & 5 deletions
diff --git a/‎lib/queue/job.js
Lines changed: 13 additions & 10 deletions b/‎lib/queue/job.js
Lines changed: 13 additions & 10 deletions
diff --git a/‎lib/redis.js
Lines changed: 15 additions & 2 deletions b/‎lib/redis.js
Lines changed: 15 additions & 2 deletions
@@ -24,7 +24,7 @@ exports = module.exports = Queue;
  * Library version.
  */
 
-exports.version = '0.6.2';
+exports.version = '0.7.0';
 
 /**
  * Expose `Job`.
@@ -61,9 +61,9 @@ exports.redis = redis;
  * @api public
  */
 
-exports.createQueue = function () {
+exports.createQueue = function ( options ) {
     if (!Queue.singleton) {
-        Queue.singleton = new Queue();
+        Queue.singleton = new Queue( options );
     }
     events.subscribe();
     return Queue.singleton;
@@ -81,10 +81,12 @@ exports.workers = [];
  * @api public
  */
 
-function Queue() {
-    this.client = redis.createClient();
+function Queue( options ) {
+    options = options || {};
+    this.client = redis.createClient( options.redis );
     this.promoter = null;
     this.workers = exports.workers;
+    this.disableSearch = options.disableSearch;
 }
 
 /**
 
@@ -363,7 +363,7 @@ Job.prototype.priority = function (level) {
 };
 
 /**
- * Increment attemps, invoking callback `fn(remaining, attempts, max)`.
+ * Increment attempts, invoking callback `fn(remaining, attempts, max)`.
  *
  * @param {Function} fn
  * @return {Job} for chaining
@@ -418,10 +418,12 @@ Job.prototype.remove = function (fn) {
 //            console.log( "removeJob", this.id, err, replies );
 //        events.remove(this);
         fn && fn(err);
-        /*if( require('../kue').singleton.searchEnabled ){
-         getSearch().remove(this.id, function(){
-         });
-         }*/
+        // TODO bad smell: change singelton access!
+        if( require('../kue').singleton.disableSearch ){
+            getSearch().remove(this.id, function(){
+                console.log( "remove index ", this.id, arguments );
+            }.bind( this ));
+        }
 //        }.bind(this));
     }.bind(this));
     return this;
@@ -613,11 +615,12 @@ Job.prototype.update = function (fn) {
         this.state(this._state, fn);
     }.bind(this));
 
-    /*if( require('../kue').singleton.searchEnabled ) {
-     // search data
-     getSearch().index(json, this.id, function(){
-     });
-     }*/
+    // TODO bad smell: change singelton access!
+    if( require('../kue').singleton.disableSearch ) {
+      getSearch().index(json, this.id, function(){
+        console.log( "add index ", this.id, arguments );
+      }.bind(this));
+    }
 };
 
 /**
 
@@ -18,8 +18,21 @@ var redis = require('redis');
  * @api private
  */
 
-exports.createClient = function () {
-    return redis.createClient();
+exports.createClient = function ( options ) {
+    var client;
+    if( options ) {
+        client = redis.createClient(
+            options.port || 6379,
+            options.host,
+            options.options || {}
+        );
+    } else {
+        client = redis.createClient();
+    }
+    client.on("error", function (err) {
+        console.error( "
5235
Redis client error ", err );
+    });
+    return client;
 };
 
 /**