@@ -32,7 +32,7 @@ exports.configureFactory = function( options, queue ) {
     options.redis = {
       port: conn_info.port || 6379,
       host: conn_info.hostname,
-      db: (conn_info.pathname ? conn_info.pathname.substr(1) : null) || 0,
+      db: (conn_info.pathname ? conn_info.pathname.substr(1) : null) || conn_info.query.db || 0,
       // see https://github.com/mranney/node_redis#rediscreateclient
       options: conn_info.query
     };