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

pubsub/rabbitpubsub: add query string set the qos prefetch count #3431

Merged
merged 7 commits into from
May 28, 2024

add same kind of validation used on kafka

ca2c5a2
Select commit
Loading
Failed to load commit list.
Merged

pubsub/rabbitpubsub: add query string set the qos prefetch count #3431

add same kind of validation used on kafka
ca2c5a2
Select commit
Loading
Failed to load commit list.
Codecov / codecov/patch succeeded May 28, 2024 in 0s

72.41% of diff hit (target 0.00%)

View this Pull Request on Codecov

72.41% of diff hit (target 0.00%)

Annotations

Check warning on line 175 in pubsub/rabbitpubsub/amqp.go

See this annotation in the file changed.

@codecov codecov / codecov/patch

pubsub/rabbitpubsub/amqp.go#L174-L175

Added lines #L174 - L175 were not covered by tests

Check warning on line 129 in pubsub/rabbitpubsub/rabbit.go

See this annotation in the file changed.

@codecov codecov / codecov/patch

pubsub/rabbitpubsub/rabbit.go#L129

Added line #L129 was not covered by tests

Check warning on line 599 in pubsub/rabbitpubsub/rabbit.go

See this annotation in the file changed.

@codecov codecov / codecov/patch

pubsub/rabbitpubsub/rabbit.go#L599

Added line #L599 was not covered by tests

Check warning on line 621 in pubsub/rabbitpubsub/rabbit.go

See this annotation in the file changed.

@codecov codecov / codecov/patch

pubsub/rabbitpubsub/rabbit.go#L620-L621

Added lines #L620 - L621 were not covered by tests