Skip to content

Force closes links when connection is closed so it requests another link.#14990

Merged
conniey merged 21 commits intoAzure:masterfrom
conniey:amqp-core-amqp-issue
Sep 10, 2020
Merged

Force closes links when connection is closed so it requests another link.#14990
conniey merged 21 commits intoAzure:masterfrom
conniey:amqp-core-amqp-issue

Conversation

@conniey
Copy link
Member

@conniey conniey commented Sep 9, 2020

There is a bug where we try to reopen the connection, but there are no downstream subscribers because the first receive link has not received a terminal signal yet. Consequently, another "amqp:connection:forced" error is propagated due to idle links, and the cycle continues.

  • The connection handler is closed first, but its children are not disposed of.
  • Removes getErrors() from Handler since an error is always a terminal signal, it can be grouped into getEndpointStates().

Fixes: #13785, #13420, #13924

@conniey conniey force-pushed the amqp-core-amqp-issue branch from 3ecd439 to 5052391 Compare September 10, 2020 06:32
@conniey conniey merged commit f2eb437 into Azure:master Sep 10, 2020
@conniey conniey deleted the amqp-core-amqp-issue branch September 10, 2020 19:10
conniey added a commit to conniey/azure-sdk-for-java that referenced this pull request Sep 11, 2020
…ink. (Azure#14990)

* Fixing the string format for Dispatch task.

* Cleaning up print statements.

* Updating text in README.md

* Remove getErrors() which overlaps with getEndpointStates(). Only ouputting one terminal state.

* Clean up tests and use subscribeWith.

* Locally closing on connection error.

* Add changelog entry
conniey added a commit that referenced this pull request Sep 11, 2020
* SB Track2: Expose AMQP details ServiceBus Messages for sending and receiving. (#14848)

Expose AMQP details ServiceBus Messages for sending and receiving.

* Force closes links when connection is closed so it requests another link. (#14990)

* Fixing the string format for Dispatch task.

* Cleaning up print statements.

* Updating text in README.md

* Remove getErrors() which overlaps with getEndpointStates(). Only ouputting one terminal state.

* Clean up tests and use subscribeWith.

* Locally closing on connection error.

* Add changelog entry

* Update versions.

* Update versions for service bus and event hubs

* Update CHANGELOG.md

Update the date on CHANGELOG

Co-authored-by: Hemant Tanwar <hemant_tanwar@hotmail.com>
openapi-sdkautomation bot pushed a commit to AzureSDKAutomation/azure-sdk-for-java that referenced this pull request Jun 25, 2021
[Python] track2 config  (Azure#14990)

* authorization

* automation

* recoveryservices

* logic

* notificationhubs

* search
openapi-sdkautomation bot pushed a commit to AzureSDKAutomation/azure-sdk-for-java that referenced this pull request Jun 25, 2021
[Python] track2 config  (Azure#14990)

* authorization

* automation

* recoveryservices

* logic

* notificationhubs

* search
openapi-sdkautomation bot pushed a commit to AzureSDKAutomation/azure-sdk-for-java that referenced this pull request Jun 25, 2021
[Python] track2 config  (Azure#14990)

* authorization

* automation

* recoveryservices

* logic

* notificationhubs

* search
openapi-sdkautomation bot pushed a commit to AzureSDKAutomation/azure-sdk-for-java that referenced this pull request Jun 25, 2021
[Python] track2 config  (Azure#14990)

* authorization

* automation

* recoveryservices

* logic

* notificationhubs

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

Labels

Projects

None yet

Development

Successfully merging this pull request may close these issues.

[BUG] EventProcessorClient is running, but no events are received

2 participants