MQTT Streaming

1.0.1

closed in 1.0.1

1.0.0 (changes since 0.20)

  • Further MQTT streaming hardening #1327

  • Resilient client publications #1315

  • Handle connect while connected #1312

  • Express the carry type #1293

  • Retire ask in favour of promise #1304

  • Improves the flow spec resilience #1296

  • Fixes around unsubscription, client connection, packet routing and stashing #1440

  • Tolerate DUP PUBLISH messages on first connecting #1436

  • Separate producer/consumer timeouts #1427

  • Fixup the continuation of a session #1414

  • More connection failure hardening #1394

  • Connection hardening #1387

  • Modal subscriptions #1341

  • Termination signal handling #1592

  • Fixes wrong QoS condition in publish message flow #1582

  • mqtt-streaming: Prefer wrapping instead of reissuing packet ids #1489

  • Parallel subscriptions/unsubscriptions and SubAck notifications #1480

  • Only publish for Scala 2.12 and 2.13 #1613

closed in 1.0.0 closed in 1.0-RC1 closed in 1.0-M3 closed in 1.0-M2 closed in 1.0-M1

Found an error in this documentation? The source code for this page can be found here. Please feel free to edit and contribute a pull request.