Skip to content

Commit

Permalink
should be no need to check if packet responds to qos
Browse files Browse the repository at this point in the history
  • Loading branch information
kickster97 committed Jan 27, 2025
1 parent a357b45 commit 94006e5
Showing 1 changed file with 1 addition and 1 deletion.
2 changes: 1 addition & 1 deletion src/lavinmq/mqtt/exchange.cr
Original file line number Diff line number Diff line change
Expand Up @@ -46,7 +46,7 @@ module LavinMQ
@publish_in_count += 1
headers = AMQP::Table.new({ RETAIN_HEADER: true }) if packet.retain?
properties = AMQP::Properties.new(headers: headers)
properties.delivery_mode = packet.qos if packet.responds_to?(:qos)
properties.delivery_mode = packet.qos

timestamp = RoughTime.unix_ms
bodysize = packet.payload.size.to_u64
Expand Down

0 comments on commit 94006e5

Please sign in to comment.