File tree Expand file tree Collapse file tree 2 files changed +12
-0
lines changed
main/java/com/netflix/suro/sink/elasticsearch
test/java/com/netflix/suro/sink/elasticsearch Expand file tree Collapse file tree 2 files changed +12
-0
lines changed Original file line number Diff line number Diff line change @@ -402,4 +402,14 @@ protected void innerClose() {
402402 RestClient getClient () {
403403 return client ;
404404 }
405+
406+ @ VisibleForTesting
407+ int getSleepOverClientException () {
408+ return sleepOverClientException ;
409+ }
410+
411+ @ VisibleForTesting
412+ boolean getReenqueueOnException () {
413+ return reEnqueueOnException ;
414+ }
405415}
Original file line number Diff line number Diff line change @@ -182,6 +182,8 @@ public Object findInjectableValue(
182182 IClientConfig config = ((BaseLoadBalancer ) client .getLoadBalancer ()).getClientConfig ();
183183 assertTrue (config .get (CommonClientConfigKey .OkToRetryOnAllOperations ));
184184 assertEquals (2 , config .get (CommonClientConfigKey .MaxAutoRetriesNextServer ).intValue ());
185+ assertEquals (0 , esSink .getSleepOverClientException ());
186+ assertFalse (esSink .getReenqueueOnException ());
185187 }
186188
187189 @ Test
You can’t perform that action at this time.
0 commit comments