|
|
|
@ -63,14 +63,12 @@ class DefaultReactiveEntityCallbacks implements ReactiveEntityCallbacks { |
|
|
|
} |
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
@Override |
|
|
|
@Override |
|
|
|
@SuppressWarnings("unchecked") |
|
|
|
@SuppressWarnings({ "unchecked", "rawtypes" }) |
|
|
|
public <T> Mono<T> callback(Class<? extends EntityCallback> callbackType, T entity, Object... args) { |
|
|
|
public <T> Mono<T> callback(Class<? extends EntityCallback> callbackType, T entity, Object... args) { |
|
|
|
|
|
|
|
|
|
|
|
Assert.notNull(entity, "Entity must not be null"); |
|
|
|
Assert.notNull(entity, "Entity must not be null"); |
|
|
|
|
|
|
|
|
|
|
|
Class<T> entityType = (Class<T>) (entity != null |
|
|
|
Class<T> entityType = (Class<T>) ClassUtils.getUserClass(entity.getClass()); |
|
|
|
? ClassUtils.getUserClass(entity.getClass()) |
|
|
|
|
|
|
|
: callbackDiscoverer.resolveDeclaredEntityType(callbackType).getRawClass()); |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
Method callbackMethod = callbackMethodCache.computeIfAbsent(callbackType, it -> { |
|
|
|
Method callbackMethod = callbackMethodCache.computeIfAbsent(callbackType, it -> { |
|
|
|
|
|
|
|
|
|
|
|
|