From 94006e55ba19bd4a6f1d0f347f6014e2df1368fa Mon Sep 17 00:00:00 2001
From: Christina <christina@84codes.com>
Date: Mon, 27 Jan 2025 11:49:29 +0100
Subject: [PATCH] should be no need to check if packet responds to qos
---
src/lavinmq/mqtt/exchange.cr | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git a/src/lavinmq/mqtt/exchange.cr b/src/lavinmq/mqtt/exchange.cr
index a795b967d0..370a5edd2b 100644
--- a/src/lavinmq/mqtt/exchange.cr
+++ b/src/lavinmq/mqtt/exchange.cr
@@ -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