Skip to content

Commit 413b6b4

Browse files
authored
Fix a problem where the ACK purge could crash on some messages (#23)
1 parent 28e5d45 commit 413b6b4

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

src/mqtt_sessions_process.erl

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1159,7 +1159,7 @@ maybe_purge_ack(WaitAcks) ->
11591159
Now = mqtt_sessions_timestamp:timestamp(),
11601160
maps:filter(
11611161
fun
1162-
(_, #wait_for{ is_sent = true, message = Msg, queued = Queued }) ->
1162+
(_, #wait_for{ is_sent = true, message = Msg, queued = Queued }) when is_map(Msg) ->
11631163
Props = maps:get(properties, Msg, #{}),
11641164
Expiry = Queued + maps:get(message_expiry_interval, Props, ?MESSAGE_EXPIRY_DEFAULT),
11651165
Expiry > Now;

0 commit comments

Comments
 (0)