Anakin100100 opened a new pull request, #408:
URL: https://github.com/apache/rocketmq-clients/pull/408
I'm trying to solve the issue described by @guyinyou in #182
The new flow of execution after transmission error looks as follows:
- we encounter a server TelemetryCommand transmission error
- we set the state of recovery to true and skip to the next loop iteration
- if there is a transmission error when we are in recovery we release the
observer and set the state of recovery to false
- if we manage to read the message we check if each of the servers is
healthy, if not we release the observer and set the state of recovery to false
- if we managed to read the message and each server is healthy we process
the message and set the state of recovery to false.
I'm going to write a unit tests for this next.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
