From 367c6bc7ceb6fca727f7898691139fe9dbb2867d Mon Sep 17 00:00:00 2001
From: Octogonapus <me@irrational.engineering>
Date: Fri, 9 Aug 2024 15:24:10 -0400
Subject: [PATCH] fix

---
 src/AWSMQTT.jl | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git a/src/AWSMQTT.jl b/src/AWSMQTT.jl
index 4780954..e5106ae 100644
--- 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,
             ),