fix

Octogonapus · Aug 9, 2024 · 367c6bc · 367c6bc
1 parent e0d6f60
commit 367c6bc
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/src/AWSMQTT.jl b/src/AWSMQTT.jl
@@ -222,7 +222,7 @@ function _c_on_connection_interrupted(
 
     data = Base.unsafe_pointer_to_objref(userdata)::_OnConnectionInterruptedUserData
     try
-        put!(data.ch, _OnConnectionInterruptedEvent(data.callback, connection, error_code))
+        put!(data.ch, _OnConnectionInterruptedEvent(data.callback, userdata.conn, error_code))
     catch ex
         if ex isa InvalidStateException && ex.state == :closed
         else
@@ -267,7 +267,7 @@ function _c_on_connection_resumed(
             data.ch,
             _OnConnectionResumedEvent(
                 data.callback,
-                connection,
+                userdata.conn,
                 aws_mqtt_connect_return_code(return_code),
                 session_present != 0,
             ),