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.

Sign up for GitHub

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

Jump to bottom

fix: emit amqp Flow on message handling completion #20

Merged
merged 11 commits into from
Feb 12, 2021
Merged

fix: emit amqp Flow on message handling completion #20

merged 11 commits into from
Feb 12, 2021

Commits on Feb 12, 2021

  1. use pending messages to decide on flow control

    @serbrech
    serbrech committed Feb 12, 2021
    Configuration menu
    Copy the full SHA
    bd2c224 View commit details
    Browse the repository at this point in the history

  2. add detailed debug logging

    @serbrech
    serbrech committed Feb 12, 2021
    Configuration menu
    Copy the full SHA
    1a5a522 View commit details
    Browse the repository at this point in the history

  3. remove unecessary parenthesis

    @serbrech
    serbrech committed Feb 12, 2021
    Configuration menu
    Copy the full SHA
    24a5048 View commit details
    Browse the repository at this point in the history

  4. add tests that shows receive failure and HandleMessage success

    @serbrech
    serbrech committed Feb 12, 2021
    Configuration menu
    Copy the full SHA
    7a6a5a5 View commit details
    Browse the repository at this point in the history

  5. lock on len(pendingMessages)

    @serbrech
    serbrech committed Feb 12, 2021
    Configuration menu
    Copy the full SHA
    f4e8d5c View commit details
    Browse the repository at this point in the history

  6. add message.Ignore() to allow consumer to explicitely control the amq… 

    …p message pump
    @serbrech
    serbrech committed Feb 12, 2021
    Configuration menu
    Copy the full SHA
    718bf94 View commit details
    Browse the repository at this point in the history

  7. add integration tests

    @serbrech
    serbrech committed Feb 12, 2021
    Configuration menu
    Copy the full SHA
    9b6dbf8 View commit details
    Browse the repository at this point in the history

  8. mod tidy

    @serbrech
    serbrech committed Feb 12, 2021
    Configuration menu
    Copy the full SHA
    4a812bf View commit details
    Browse the repository at this point in the history

  9. remove dependency on amqp-common

    @serbrech
    serbrech committed Feb 12, 2021
    Configuration menu
    Copy the full SHA
    cbf589e View commit details
    Browse the repository at this point in the history

  10. re-add the build tag that got yanked in rebase

    @serbrech
    serbrech committed Feb 12, 2021
    Configuration menu
    Copy the full SHA
    b15705f View commit details
    Browse the repository at this point in the history

  11. rename pending to unsettled

    @serbrech
    serbrech committed Feb 12, 2021
    Configuration menu
    Copy the full SHA
    5ddef8b View commit details
    Browse the repository at this point in the history