diff --git a/Source/AwsCommonRuntimeKit/mqtt/Mqtt5Client.swift b/Source/AwsCommonRuntimeKit/mqtt/Mqtt5Client.swift
index 2d9aedfb..fbd09e37 100644
--- a/Source/AwsCommonRuntimeKit/mqtt/Mqtt5Client.swift
+++ b/Source/AwsCommonRuntimeKit/mqtt/Mqtt5Client.swift
@@ -456,10 +456,10 @@ internal func MqttClientWebsocketTransform(
     _ complete_fn: (@convention(c) (OpaquePointer?, Int32, UnsafeMutableRawPointer?) -> Void)?,
     _ complete_ctx: UnsafeMutableRawPointer?) {
 
-    let client = Unmanaged<Mqtt5Client>.fromOpaque(complete_ctx!).takeUnretainedValue()
+    let client = Unmanaged<Mqtt5Client>.fromOpaque(user_data!).takeUnretainedValue()
 
     // validate the callback flag, if flag is false, return
-        client.rwlock.read {
+    client.rwlock.read {
         if client.callbackFlag == false { return }
 
         guard let request else {