Skip to content

Add ability to pause / unpause consumers #41

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

Merged
merged 1 commit into from
Aug 7, 2024

Conversation

lukebakken
Copy link
Contributor

Fixes #37

@lukebakken lukebakken self-assigned this Jul 30, 2024
@lukebakken lukebakken added this to the 0.1.0 milestone Jul 30, 2024
@lukebakken lukebakken requested a review from Gsantomaggio August 7, 2024 19:25
@lukebakken lukebakken marked this pull request as ready for review August 7, 2024 21:24
Fixes #37

* Begin by copying test from Java AMQP client.

* Continue fleshing out `ConsumerPauseTests`

* Use async/await to ensure management links are started up in order.

* Add method to get `IQueueInfo`

* Rename some async methods to end with `Async` suffix

* Finish implementation of `GetQueueInfoAsync`

* Bump up retries

* Do not `stopOnFail` when running tests

* More work on `PauseShouldStopMessageArrivalUnpauseShouldResumeIt` test

* Move HTTP API code that uses `EasyNetQ.Management.Client` to its own class

* Make publisher and consumer builders OpenAsync

* Implement `IConsumer.Pause`

* Add `Pause` to test and it appears to work correctly, huzzah

* Renaming methods that return `Task` or `Task<T>` to end with `Async` suffic

* Re-ordering methods in `AmqpConnection` so that they are in public, internal, private order
* Enable semaphores in `AmqpConnection` and add `IDisposable`

* Implement `Unpause`

* Finish `PauseShouldStopMessageArrivalUnpauseShouldResumeIt` test
@lukebakken lukebakken force-pushed the rabbitmq-amqp-dotnet-client-37 branch from fb55b26 to ef8dc73 Compare August 7, 2024 23:34
@lukebakken lukebakken merged commit d1b83aa into main Aug 7, 2024
1 check passed
@lukebakken lukebakken deleted the rabbitmq-amqp-dotnet-client-37 branch August 7, 2024 23:38
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Labels
None yet
Projects
None yet
Development

Successfully merging this pull request may close these issues.

Complete the consumer part with pause and unpause
1 participant