Movatterモバイル変換


[0]ホーム

URL:


Skip to content

Navigation Menu

Sign in
Appearance settings

Search code, repositories, users, issues, pull requests...

Provide feedback

We read every piece of feedback, and take your input very seriously.

Saved searches

Use saved searches to filter your results more quickly

Sign up
Appearance settings

Fix shovel with AMQP 1.0 dest always being in flow state#15163

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 ourterms of service andprivacy statement. We’ll occasionally send you account related emails.

Already on GitHub?Sign in to your account

Draft
gomoripeti wants to merge1 commit intorabbitmq:main
base:main
Choose a base branch
Loading
fromcloudamqp:amqp_10_shovel_flow

Conversation

@gomoripeti
Copy link
Contributor

Proposed Changes

The link_state field should be under State.dest.current and the pending field should be under State.dest. Field being expected or put in the wrong place caused multiple function clauses not matching. Because of this the credited link event was never processed. But also a link_state=attached did not prevent messages to be forwarded. So the shovel accidentally worked fine.

I only tested manually, and did not even test when the shovel is really blocked and should cumulate some pending messages. Test cases need to be added, hence opening a draft PR.

Types of Changes

What types of changes does your code introduce to this project?
Put anx in the boxes that apply

  • Bug fix (non-breaking change which fixes issue #NNNN)
  • New feature (non-breaking change which adds functionality)
  • Breaking change (fix or feature that would cause an observable behavior change in existing systems)
  • Documentation improvements (corrections, new content, etc)
  • Cosmetic change (whitespace, formatting, etc)
  • Build system and/or CI

Checklist

Put anx in the boxes that apply.
You can also fill these out after creating the PR.
This is simply a reminder of what we are going to look for before merging your code.

  • Mandatory: I (or my employer/client) have have signed the CA (seehttps://github.com/rabbitmq/cla)
  • I have read theCONTRIBUTING.md document
  • I have added tests that prove my fix is effective or that my feature works
  • All tests pass locally with my changes
  • If relevant, I have added necessary documentation tohttps://github.com/rabbitmq/rabbitmq-website
  • If relevant, I have added this change to the first version(s) in release-notes that I expect to introduce it

Further Comments

If this is a relatively large or complex change, kick off the discussion by explaining why you chose the solution
you did and what alternatives you considered, etc.

The link_state field should be under State.dest.current and thepending field should be under State.dest. Because of this the creditedlink event was never processed. But also a link_state=attached did notprevent messages to be forwarded. So the shovel accidentally workedfine.
@michaelklishin
Copy link
Collaborator

The analysis looks correct to me. Thank you,@gomoripeti.

Sign up for freeto join this conversation on GitHub. Already have an account?Sign in to comment

Reviewers

No reviews

Assignees

No one assigned

Labels

None yet

Projects

None yet

Milestone

No milestone

Development

Successfully merging this pull request may close these issues.

2 participants

@gomoripeti@michaelklishin

[8]ページ先頭

©2009-2025 Movatter.jp