diff --git a/CHANGES.md b/CHANGES.md
index 24006dd..db3dcdb 100644
--- a/CHANGES.md
+++ b/CHANGES.md
@@ -1,5 +1,9 @@
 # Changes
 
+## [0.8.1] - 2023-06-23
+
+* Fix client connector usage, fixes lifetime constraint
+
 ## [0.8.0] - 2023-06-22
 
 * Release v0.8.0
diff --git a/Cargo.toml b/Cargo.toml
index d70f203..e25ff9d 100644
--- a/Cargo.toml
+++ b/Cargo.toml
@@ -1,6 +1,6 @@
 [package]
 name = "ntex-amqp"
-version = "0.8.0"
+version = "0.8.1"
 authors = ["ntex contributors <team@ntex.rs>"]
 description = "AMQP 1.0 Client/Server framework"
 documentation = "https://docs.rs/ntex-amqp"
@@ -24,7 +24,7 @@ default = []
 frame-trace = []
 
 [dependencies]
-ntex = "0.7.0"
+ntex = "0.7.2"
 ntex-amqp-codec = "0.9.0"
 
 bitflags = "1.3"
@@ -36,7 +36,7 @@ uuid = { version = "1", features = ["v4"] }
 
 [dev-dependencies]
 env_logger = "0.10"
-ntex = { version = "0.7.0", features = ["tokio"] }
+ntex = { version = "0.7.2", features = ["tokio"] }
 
 [patch.crates-io]
 ntex-amqp = { path = "." }
diff --git a/src/client/connector.rs b/src/client/connector.rs
index 78676b8..e4a005d 100644
--- a/src/client/connector.rs
+++ b/src/client/connector.rs
@@ -164,7 +164,11 @@ where
     }
 
     async fn _connect(&self, address: A) -> Result<Client, ConnectError> {
-        let io = self.connector.call(Connect::new(address)).await?;
+        let io = self
+            .connector
+            .clone()
+            .service_call(Connect::new(address))
+            .await?;
         let config = self.config.clone();
         let pool = self.pool;
         let disconnect = self.disconnect_timeout;
@@ -203,7 +207,11 @@ where
     }
 
     async fn _connect_sasl(&self, addr: A, auth: SaslAuth) -> Result<Client, ConnectError> {
-        let io = self.connector.call(Connect::new(addr)).await?;
+        let io = self
+            .connector
+            .clone()
+            .service_call(Connect::new(addr))
+            .await?;
         let config = self.config.clone();
         let pool = self.pool;
         let disconnect = self.disconnect_timeout;