[Bug] Subscription is almost impossible to be cancelled when the TCP sub client is closed #4144
Description
Search before asking
- I had searched in the issues and found no similar issues.
Environment
Windows
EventMesh version
master
What happened
When the TCP subscriber is closed, eventmesh-runtime is still subscribing to related topics.
How to reproduce
Use org.apache.eventmesh.tcp.demo.pub.cloudevents.AsyncPublish in eventmesh-examples to push messages.
Use org.apache.eventmesh.tcp.demo.sub.cloudevents.AsyncSubscribe in eventmesh-examples to subscribe the topic. After message are consumed successfully, close AsyncSubscribe.
Use org.apache.eventmesh.tcp.demo.pub.cloudevents.AsyncPublish in eventmesh-examples to push messages again. Then some messages will still be consumed. This should not happen.
Debug logs
No response
Are you willing to submit PR?
- Yes I am willing to submit a PR!