Skip to content

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
@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

2 participants