Coverage for faststream / mqtt / message.py: 80%

1import zmqtt (empty)

2 

3from faststream.message import StreamMessage (empty)

4 

5 

6class MQTTMessage(StreamMessage[zmqtt.Message]): (empty)

7 """A class to represent an MQTT message.""" 

8 

9 async def ack(self) -> None: (empty)

10 if self.committed is None and self.raw_message.qos != zmqtt.QoS.AT_MOST_ONCE: 10 ↛ 11line 10 didn't jump to line 11 because the condition on line 10 was never true(empty)

11 await self.raw_message.ack() 

12 await super().ack() (empty)

13 

14 async def nack(self) -> None: (empty)

15 pass # MQTT has no protocol-level nack; with auto_ack=False broker redelivers QoS 1/2 messages (empty)

16 

17 async def reject(self) -> None: (empty)

18 await self.ack() # MQTT has no reject; acknowledge to prevent redelivery (empty)