diff --git a/_src/index.ts b/_src/index.ts
index d3899c2..a549995 100644
--- a/_src/index.ts
+++ b/_src/index.ts
@@ -65,7 +65,7 @@ class RedisSMQ extends EventEmitter {
 			this.redis = opts.client
 		}
 		else {
-			this.redis = RedisInst.createClient(opts)
+			this.redis = RedisInst.createClient(opts.options)
 		}
 
 		this.connected = this.redis.connected || false;
diff --git a/index.js b/index.js
index 36b21a9..4d850ad 100644
--- a/index.js
+++ b/index.js
@@ -521,7 +521,7 @@ class RedisSMQ extends EventEmitter {
             this.redis = opts.client;
         }
         else {
-            this.redis = RedisInst.createClient(opts);
+            this.redis = RedisInst.createClient(opts.options);
         }
         this.connected = this.redis.connected || false;
         if (this.connected) {