Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

mqtt-streaming: Various fixes #1595

Merged
merged 5 commits into from
Mar 26, 2019
Merged

mqtt-streaming: Various fixes #1595

merged 5 commits into from
Mar 26, 2019

Commits on Mar 25, 2019

  1. mqtt-streaming: Require a connection id to be specified for client flows

    This allows the MQTT session to better track which events are relevant,
    given that there can be races when old connections are torn down and new
    ones are established.
    longshorej committed Mar 25, 2019
    Configuration menu
    Copy the full SHA
    ae488a0 View commit details
    Browse the repository at this point in the history
  2. mqtt-streaming: Fix a bug where actor state was closed over

    This could cause duplicate publications to never be sent to new
    connections
    longshorej committed Mar 25, 2019
    Configuration menu
    Copy the full SHA
    0323c25 View commit details
    Browse the repository at this point in the history
  3. mqtt-streaming: Republish messages on reconnect only by default

    Previously, messages for QoS1/2 were only republished on an interval
    after not receiving an ack.
    
    It is more conventional to instead republish everything only on connect,
    and indeed to be compliant for MQTT 5, that is the only time this is
    allowed.
    
    To accomodate this, the timeouts default to 0, but the previous behavior
    can still be restored by changing the default producer timeout settings.
    longshorej committed Mar 25, 2019
    Configuration menu
    Copy the full SHA
    0e260c4 View commit details
    Browse the repository at this point in the history
  4. Configuration menu
    Copy the full SHA
    be6af71 View commit details
    Browse the repository at this point in the history
  5. Configuration menu
    Copy the full SHA
    9fc6f1c View commit details
    Browse the repository at this point in the history