Corrected building classified Concurrent Map for retryable Exceptions.

This commit is contained in:
Nikhil Kharche
2018-12-15 22:49:27 +05:30
committed by Dave Syer
parent c5a28f4fa4
commit eec9a1c247

View File

@@ -114,15 +114,15 @@ public class SubclassClassifier<T, C> implements Classifier<T, C> {
value = classified.get(cls);
}
if (value == null) {
value = defaultValue;
}
//ConcurrentHashMap doesn't allow nulls
if (value != null) {
this.classified.put(exceptionClass, value);
}
if (value == null) {
value = defaultValue;
}
return value;
}