You signed in with another tab or window. Reload to refresh your session.You signed out in another tab or window. Reload to refresh your session.You switched accounts on another tab or window. Reload to refresh your session.Dismiss alert
I experienced a crash after a connection interruption due to an authorization error (due to publishing to a topic I didn't have permissions for). I'm not sure if this is a bug in my wrapper or in the C libraries.
AWSCRT v0.1.0. Julia v1.7.2.
mqtt_client =MQTTClient(
ClientTLSContext(
create_client_with_mtls(
certificate_pem,
private_key;
ca_filepath =joinpath(@__DIR__, "AmazonRootCA1.pem"),
),
),
)
mqtt_connection =MQTTConnection(mqtt_client)
t =connect(
mqtt_connection,
terraform_output(env, "endpoint_url"),
8883,
mqtt_client_id;
on_connection_interrupted = (conn, error_code) ->begin@warn"MQTT connection interrupted: $(AWSCRT.aws_err_string(error_code))"end,
on_connection_resumed = (conn, return_code, session_present) ->begin@info"MQTT connection resumed" return_code session_present
if!session_present
# the server forgot all our subscriptions, so we have to resubscribe from our end
resub_task =resubscribe_existing_topics(conn)
@asyncbegin
resub_task_result =fetch(resub_task)
@info"Resubscribed existing topics" resub_task_result
endendend,
)
I experienced a crash after a connection interruption due to an authorization error (due to publishing to a topic I didn't have permissions for). I'm not sure if this is a bug in my wrapper or in the C libraries.
AWSCRT v0.1.0. Julia v1.7.2.
The text was updated successfully, but these errors were encountered: