Skip to content

Commit 80d0d1c

Browse files
authored
FMWK-383 Fix Infinite Loop on Error Mapping (#155)
Remove redundant error translation that causes infinite loops (copied from Spring which required error translation).
1 parent f6320cf commit 80d0d1c

File tree

1 file changed

+1
-9
lines changed

1 file changed

+1
-9
lines changed

src/main/java/com/aerospike/mapper/tools/ReactiveAeroMapper.java

+1-9
Original file line numberDiff line numberDiff line change
@@ -101,8 +101,7 @@ private <T> Mono<T> save(WritePolicy writePolicy, @NotNull T object, RecordExist
101101

102102
return reactorClient
103103
.put(writePolicy, key, bins)
104-
.map(docKey -> object)
105-
.onErrorMap(this::translateError);
104+
.map(docKey -> object);
106105
}
107106

108107
@Override
@@ -417,13 +416,6 @@ private Policy getPolicyByClassAndType(Class<?> clazz, ClassCache.PolicyType pol
417416
}
418417
}
419418

420-
private Throwable translateError(Throwable e) {
421-
if (e instanceof AerospikeException) {
422-
return translateError(e);
423-
}
424-
return e;
425-
}
426-
427419
@Override
428420
public <T> Mono<String> getNamespace(Class<T> clazz) {
429421
ClassCacheEntry<T> entry = MapperUtils.getEntryAndValidateNamespace(clazz, this);

0 commit comments

Comments
 (0)