This commit is contained in:
Marcin Grzejszczak
2021-12-07 09:52:46 +01:00
parent fe23348513
commit faa2c0fa53
3 changed files with 3 additions and 12 deletions

View File

@@ -82,17 +82,8 @@ abstract class AbstractTransactionManagerInstrumenter<T extends TransactionManag
abstract T wrap(T transactionManager);
/**
* Wraps an {@link Executor} bean in its trace representation.
* @param bean a bean (might be of {@link Executor} type
* @param beanName name of the bean
* @return wrapped bean or just bean if not {@link Executor} or already instrumented
*/
Object instrument(Object bean, String beanName) {
Object instrument(Object bean) {
if (!isApplicableForInstrumentation(bean)) {
if (log.isTraceEnabled()) {
log.trace("Bean is already instrumented or is not applicable for instrumentation " + beanName);
}
return bean;
}
return wrapManager(bean);

View File

@@ -37,7 +37,7 @@ public class TracePlatformTransactionManagerBeanPostProcessor implements BeanPos
@Override
public Object postProcessAfterInitialization(Object bean, String beanName) throws BeansException {
return this.platformTransactionManagerInstrumenter.instrument(bean, beanName);
return this.platformTransactionManagerInstrumenter.instrument(bean);
}
}

View File

@@ -37,7 +37,7 @@ public class TraceReactiveTransactionManagerBeanPostProcessor implements BeanPos
@Override
public Object postProcessAfterInitialization(Object bean, String beanName) throws BeansException {
return this.reactiveTransactionManagerInstrumenter.instrument(bean, beanName);
return this.reactiveTransactionManagerInstrumenter.instrument(bean);
}
}