[Issue 733] Fix using closed connection in producer/consumer.

[sunby]

Fixes #733

Motivation

See issue #733

Modifications

Return error if connection is closed.
The modification of consumer is the same as producer.

Verifying this change

• Make sure that the change passes the CI checks.

Does this pull request potentially affect one of the following parts:

If yes was chosen, please highlight the changes

• Dependencies (does it add or upgrade a dependency): (no)
• The public API: (no)
• The schema: (no)
• The default values of configurations: (no)
• The wire protocol: (no)

Documentation

• Does this pull request introduce a new feature? ( no)

[liangyuanpeng]

Can you provide some code for reproduce it? I have tested consumer and it is always working.

[sunby]

Can you provide some code for reproduce it? I have tested consumer and it is always working.

It's not stable to reproduce but I will have a try.

[lhotari]

@sunby Please resolve the conflict in this PR by rebasing the changes (or merging master to PR branch).

[lhotari]

It seems that #761 contains a similar change. @sunby can you check that?

[wolfstudy]

It seems that #761 contains a similar change. @sunby can you check that?

Yes, #761 has already dealt with this problem, I will close this pr first, if #761 cannot fix the current problem, please reopen this pr at any time.

[sunby]

It seems that #761 contains a similar change. @sunby can you check that?

Yes, #761 has already dealt with this problem, I will close this pr first, if #761 cannot fix the current problem, please reopen this pr at any time.

Thanks for this fix! Does the AddConsumeHandler have the same issue with RegisterListener?