net-mqtt 0.6.1.0 → 0.6.1.1

raw patch · 3 files changed

+12/−4 lines, 3 filesPVP ok

version bump matches the API change (PVP)

API changes (from Hackage documentation)

Files

• Changelog.md +8/−0
• net-mqtt.cabal +2/−2
• src/Network/MQTT/Client.hs +2/−2

@@ -1,5 +1,13 @@ # Changelog for net-mqtt +## 0.6.1.1++Add connection checks to publish phases.++Having a broker/connection die in the middle of a publish in QoS > 0+could result in a thread waiting indefinitely for the response that+would not ever arrive.+ ## 0.6.1.0  Users can now specify TLSSettings for mqtts:// and wss:// connections.

@@ -4,10 +4,10 @@ -- -- see: https://github.com/sol/hpack ----- hash: 37d707924711ee323b90898ae6a53dfe919a58be4f6484ee60ce0028ce6b2bb2+-- hash: 6c69102312ff4cecc87356752a2c3125e4e9aa010ece324b5d191f234c89616c  name:           net-mqtt-version:        0.6.1.0+version:        0.6.1.1 synopsis:       An MQTT Protocol Implementation. description:    Please see the README on GitHub at <https://github.com/dustin/mqtt-hs#readme> category:       Network

@@ -588,14 +588,14 @@       satisfyQoS p ch pid         | q == QoS0 = pure ()         | q == QoS1 = void $ do-            (PubACKPkt (PubACK _ st pprops)) <- atomically $ readTChan ch+            (PubACKPkt (PubACK _ st pprops)) <- atomically $ checkConnected c >> readTChan ch             when (st /= 0) $ mqttFail ("qos 1 publish error: " <> show st <> " " <> show pprops)         | q == QoS2 = waitRec         | otherwise = error "invalid QoS"          where           waitRec = do-            rpkt <- atomically $ readTChan ch+            rpkt <- atomically $ checkConnected c >> readTChan ch             case rpkt of               PubRECPkt (PubREC _ st recprops) -> do                 when (st /= 0) $ mqttFail ("qos 2 REC publish error: " <> show st <> " " <> show recprops)