|
|
|
@ -112,7 +112,7 @@ public class PrePostAdviceReactiveMethodInterceptor implements MethodInterceptor |
|
|
|
); |
|
|
|
); |
|
|
|
} |
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
private<T extends Publisher<?>> T proceed(final MethodInvocation invocation) { |
|
|
|
private static <T extends Publisher<?>> T proceed(final MethodInvocation invocation) { |
|
|
|
try { |
|
|
|
try { |
|
|
|
return (T) invocation.proceed(); |
|
|
|
return (T) invocation.proceed(); |
|
|
|
} catch(Throwable throwable) { |
|
|
|
} catch(Throwable throwable) { |
|
|
|
@ -131,7 +131,7 @@ public class PrePostAdviceReactiveMethodInterceptor implements MethodInterceptor |
|
|
|
return null; |
|
|
|
return null; |
|
|
|
} |
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
private PreInvocationAttribute findPreInvocationAttribute( |
|
|
|
private static PreInvocationAttribute findPreInvocationAttribute( |
|
|
|
Collection<ConfigAttribute> config) { |
|
|
|
Collection<ConfigAttribute> config) { |
|
|
|
for (ConfigAttribute attribute : config) { |
|
|
|
for (ConfigAttribute attribute : config) { |
|
|
|
if (attribute instanceof PreInvocationAttribute) { |
|
|
|
if (attribute instanceof PreInvocationAttribute) { |
|
|
|
|