Skip to content

Implement the Environment class to manage the connections #36

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 4 commits into from
Jul 26, 2024

Conversation

Gsantomaggio
Copy link
Member

@Gsantomaggio Gsantomaggio commented Jul 26, 2024

Closes #35

Implement IEnvironment:

const string connectionName = "my-connection-name";

IEnvironment environment = await AmqpEnvironment.CreateAsync(ConnectionSettingBuilder.Create().ConnectionName(connectionName).Build()).ConfigureAwait(false);

IConnection connection = await environment.CreateConnectionAsync().ConfigureAwait(false);

Closes #35

Signed-off-by: Gabriele Santomaggio <[email protected]>
Signed-off-by: Gabriele Santomaggio <[email protected]>
@Gsantomaggio Gsantomaggio added this to the 0.1.0 milestone Jul 26, 2024
@Gsantomaggio Gsantomaggio requested a review from lukebakken July 26, 2024 12:50
Signed-off-by: Gabriele Santomaggio <[email protected]>
Signed-off-by: Gabriele Santomaggio <[email protected]>
@Gsantomaggio Gsantomaggio changed the title Implment the Environment Implement the Environment class to manage the connections Jul 26, 2024
@Gsantomaggio Gsantomaggio marked this pull request as ready for review July 26, 2024 13:40
@Gsantomaggio Gsantomaggio merged commit 64564b2 into main Jul 26, 2024
1 check passed
@Gsantomaggio Gsantomaggio deleted the environment branch July 26, 2024 13:46
lukebakken pushed a commit that referenced this pull request Jul 26, 2024
* Implement the Environment Closes #35
---------

Signed-off-by: Gabriele Santomaggio <[email protected]>
lukebakken added a commit that referenced this pull request Jul 26, 2024
* Allow specifying `MaxFrameSize` for a connection.
* Move HTTP API interaction to `EasyNetQ.Management.Client`

* No need to start toxiproxy yet

* Use `uint.MinValue` to mean `unlimited` for max frame size
*

Implement the Environment class to manage the connections (#36)

* Implement the Environment Closes #35
---------

Signed-off-by: Gabriele Santomaggio <[email protected]>

Use `EasyNetQ.Management.Client`

* Allow specifying `MaxFrameSize` for a connection.
* Move HTTP API interaction to `EasyNetQ.Management.Client`

* No need to start toxiproxy yet

* Use `uint.MinValue` to mean `unlimited` for max frame size
*

* Add to public API
lukebakken added a commit that referenced this pull request Jul 26, 2024
* Allow specifying `MaxFrameSize` for a connection.
* Move HTTP API interaction to `EasyNetQ.Management.Client`

* No need to start toxiproxy yet

* Use `uint.MinValue` to mean `unlimited` for max frame size
*

Implement the Environment class to manage the connections (#36)

* Implement the Environment Closes #35
---------

Signed-off-by: Gabriele Santomaggio <[email protected]>

Use `EasyNetQ.Management.Client`

* Allow specifying `MaxFrameSize` for a connection.
* Move HTTP API interaction to `EasyNetQ.Management.Client`

* No need to start toxiproxy yet

* Use `uint.MinValue` to mean `unlimited` for max frame size
*

* Add to public API

Continue migrating to EasyNetQ.Management.Client
lukebakken added a commit that referenced this pull request Jul 29, 2024
* Use `EasyNetQ.Management.Client`

* Allow specifying `MaxFrameSize` for a connection.
* Move HTTP API interaction to `EasyNetQ.Management.Client`

* No need to start toxiproxy yet

* Use `uint.MinValue` to mean `unlimited` for max frame size
*

Implement the Environment class to manage the connections (#36)

* Implement the Environment Closes #35
---------

Signed-off-by: Gabriele Santomaggio <[email protected]>

Use `EasyNetQ.Management.Client`

* Allow specifying `MaxFrameSize` for a connection.
* Move HTTP API interaction to `EasyNetQ.Management.Client`

* No need to start toxiproxy yet

* Use `uint.MinValue` to mean `unlimited` for max frame size
*

* Add to public API

Continue migrating to EasyNetQ.Management.Client

* * Use `EasyNetQ.Management.Client` to determine exchange existence.

* * Use `EasyNetQ.Management.Client` to check for exchange/queue bindings

* * Use `EasyNetQ.Management.Client` to kill connections.

* * Migrate binding checks with arguments to `EasyNetQ.Management.Client`

* * Migrate exchange-exchange binding checks to `EasyNetQ.Management.Client`

* * Move retrieval of queue message count to `EasyNetQ.Management.Client`

* * Finish conversion to `EasyNetQ.Management.Client`

* * Extend retries to accomodate GHA

* * Double the retries in CI
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.

Add the Environment
1 participant