Fix the deadlock in the dispatcher #1369

[ckyoog]

It occurs when the rabbitmq server is down while the dispatcher is waiting for the response from the subscriber.

See #1369 for details.

[linux-foundation-easycla]

The committers listed above are authorized under a signed CLA.

• ✅ login: ckyoog / name: Yu Kou (f292c47, 1db3bb0)

[knative-prow]

Welcome @ckyoog! It looks like this is your first PR to knative-extensions/eventing-rabbitmq 🎉

[dprotaso]

/assign @ikavgo @Zerpet @mkuratczyk

[dprotaso]

hey @ckyoog thanks for the PR. You'll have to sign the CLA - can you follow the instructions by clicking on the red boxes in this comment - #1370 (comment)

[codecov]

Codecov Report

Attention: Patch coverage is 33.33333% with 8 lines in your changes are missing coverage. Please review.

Project coverage is 64.66%. Comparing base (9b15d3b) to head (f292c47).
Report is 7 commits behind head on main.

Files	Patch %	Lines
pkg/dispatcher/dispatcher.go	11.11%	8 Missing ⚠️

Additional details and impacted files

@@            Coverage Diff             @@
##             main    #1370      +/-   ##
==========================================
+ Coverage   63.16%   64.66%   +1.49%     
==========================================
  Files          60       60              
  Lines        4333     3574     -759     
==========================================
- Hits         2737     2311     -426     
+ Misses       1481     1148     -333     
  Partials      115      115              

☔ View full report in Codecov by Sentry.
📢 Have feedback on the report? Share it here.

[dprotaso]

closing and re-opening to refresh and get the latest github actions

[ikavgo]

@ckyoog please look here - #1370 (comment) this email thingy prevents merge

[ckyoog]

Hi I was using a wrong email address in the commits. I just corrected them. I am wondering, if I used the right email address in the first place, would I still need to sign the CLA? Just curious.

[ikavgo]

/override "codecov/patch"

[knative-prow]

@ikavgo: ikavgo unauthorized: /override is restricted to Repo administrators.

In response to this:

/override "codecov/patch"

Instructions for interacting with me using PR comments are available here. If you have questions or suggestions related to my behavior, please file an issue against the kubernetes/test-infra repository.

[knative-prow]

[APPROVALNOTIFIER] This PR is APPROVED

This pull-request has been approved by: ckyoog, ikavgo

The full list of commands accepted by this bot can be found here.

The pull request process is described here

Needs approval from an approver in each of these files:

• OWNERS [ikavgo]

Approvers can indicate their approval by writing /approve in a comment
Approvers can cancel approval by writing /approve cancel in a comment

[dprotaso]

/override "codecov/patch"

[knative-prow]

@dprotaso: Overrode contexts on behalf of dprotaso: codecov/patch

In response to this:

/override "codecov/patch"

Instructions for interacting with me using PR comments are available here. If you have questions or suggestions related to my behavior, please file an issue against the kubernetes/test-infra repository.