You signed in with another tab or window. Reload to refresh your session.You signed out in another tab or window. Reload to refresh your session.You switched accounts on another tab or window. Reload to refresh your session.Dismiss alert
When a topic is deleted, a regex subscriber should simply gracefully close the individual consumer and move on.
Actual behavior
As I mention in apache#432, the client throws a series of scary-looking errors as it attempts to resubscribe to the topic, but is blocked by its own specified desire not to create new topics. It then retries the operation a series of times.
Since the consumer already knows it doesn't want to create a new topic, and since the error returned from the server explicitly states that the topic doesn't exist, the consumer could put two and two together and realize that it shouldn't keep retrying the consumer. Unfortunately, at the moment, the error is returned from connection.handleResponseError() as a string:
Original Issue: apache#434
Expected behavior
When a topic is deleted, a regex subscriber should simply gracefully close the individual consumer and move on.
Actual behavior
As I mention in apache#432, the client throws a series of scary-looking errors as it attempts to resubscribe to the topic, but is blocked by its own specified desire not to create new topics. It then retries the operation a series of times.
Steps to reproduce
As with apache#432, once apache#433 is applied.
Suggested fix
Since the consumer already knows it doesn't want to create a new topic, and since the error returned from the server explicitly states that the topic doesn't exist, the consumer could put two and two together and realize that it shouldn't keep retrying the consumer. Unfortunately, at the moment, the error is returned from
connection.handleResponseError()
as a string:Since
handleResponseError()
already has the*pb.CommandError
, it could conceivably wrap the message in a type like the followingBecause
ServerError
is a proto enum, it should be safe enough to just callEnum().String()
and select off of that when handling the error.The text was updated successfully, but these errors were encountered: