RenJuan/TASKPM
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

Add mechanism for handling OptimisticLockingFailureException on random objects

Browse source 
It uses a transparent proxy.

FEA: ItEr74S04BugFixing
This commit is contained in:
Óscar González Fernández 2011-05-09 15:58:27 +02:00
parent 04a510878c
commit 82b825e071
1 changed files with 35 additions and 0 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

35
navalplanner-webapp/src/main/java/org/navalplanner/web/common/concurrentdetection/ConcurrentModificationHandling.java
View file

@ -21,6 +21,11 @@
package org.navalplanner.web.common.concurrentdetection;
import java.lang.reflect.InvocationHandler;
import java.lang.reflect.InvocationTargetException;
import java.lang.reflect.Method;
import java.lang.reflect.Proxy;
import org.aspectj.lang.ProceedingJoinPoint;
import org.aspectj.lang.annotation.Around;
import org.aspectj.lang.annotation.Aspect;
@ -37,6 +42,36 @@ import org.springframework.dao.OptimisticLockingFailureException;
@Order(0)
public class ConcurrentModificationHandling {
public static <T> T addHandling(final String goToPage,
Class<T> interfaceKlass, T toBeWraped) {
Class<?>[] classesToProxy = { interfaceKlass };
Object result = Proxy.newProxyInstance(interfaceKlass.getClassLoader(),
classesToProxy, handler(toBeWraped, goToPage));
return interfaceKlass.cast(result);
}
private static InvocationHandler handler(final Object toBeWraped,
final String goToPage) {
return new InvocationHandler() {
@Override
public Object invoke(Object proxy, Method method,
Object[] args) throws Throwable {
try {
return method.invoke(toBeWraped, args);
} catch (InvocationTargetException e) {
Throwable cause = e.getCause();
if (cause instanceof OptimisticLockingFailureException) {
OptimisticLockingFailureException optimisticLockingFailureException = (OptimisticLockingFailureException) cause;
ConcurrentModificationController.showException(
optimisticLockingFailureException, goToPage);
}
throw e;
}
}
};
}
public ConcurrentModificationHandling() {
}