From 8de48339d3953c79af6ad1d853664edd4a1030ab Mon Sep 17 00:00:00 2001 From: Lev Brouk Date: Thu, 31 Aug 2023 12:46:13 -0700 Subject: [PATCH] Fixed: MQTT: more consistent name for PUBREL durable --- server/mqtt.go | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/server/mqtt.go b/server/mqtt.go index d0c23e20..527436ae 100644 --- a/server/mqtt.go +++ b/server/mqtt.go @@ -126,6 +126,7 @@ const ( // Stream name and subjects for outgoing MQTT QoS2 PUBREL messages mqttQoS2PubRelStreamName = "$MQTT_qos2out" + mqttQoS2PubRelConsumerDurablePrefix = "$MQTT_PUBREL_" mqttQoS2PubRelStoredSubjectPrefix = "$MQTT.qos2.out." mqttQoS2PubRelDeliverySubjectPrefix = "$MQTT.qos2.delivery." @@ -4465,7 +4466,7 @@ func (sess *mqttSession) ensurePubRelConsumerSubscription(c *client) error { Stream: mqttQoS2PubRelStreamName, Config: ConsumerConfig{ DeliverSubject: sess.pubRelDeliverySubject, - Durable: sess.idHash + "_pubrel", + Durable: mqttQoS2PubRelConsumerDurablePrefix + sess.idHash, AckPolicy: AckExplicit, DeliverPolicy: DeliverNew, FilterSubject: sess.pubRelSubject,