Closed nsoft closed 4 years ago
The RoundRobinRouter class was meant to provide a load balancing type of effect, but StepImpl is doing a blocking put() so if one queue fills up because one of several candidates has a full queue, we are unable to try the next step in the rotation.
The RoundRobinRouter class was meant to provide a load balancing type of effect, but StepImpl is doing a blocking put() so if one queue fills up because one of several candidates has a full queue, we are unable to try the next step in the rotation.