This exception is being emitted from WorkerThreadManager because something below it is blowing up but we cant see as I mentioned before because the exception it's throwing is a wrapper.
The method execute should be replaced with:
This won't solve your problem but it will tell you what the actual problem is or at the very least get you one step closer to the real problem (I don't know maybe you will encounter another wrapped exception – there are a number of wrappers and dynamic proxies at play here)
I don't have time to compile, test and build this – it's almost 5am here and I've been up since 8am yesterday – gotta run. I'll commit the change. If you don't have an extension environment or the source base maybe Lennard can fix my syntax errors and hook you up.
Good luck!
-R
The method execute should be replaced with:
/**
* Requests WorkerThread associated with threadKey execute the dispatched
* method, using dispatched parameters, against the target object
*
* @param threadKey
* key associated with worker thread
* @param target
* target object against which dispatched method with dispatched
* params should be ran.
* @param dispatchedMethod method which should be ran against target object
* @param dispatchedParams params which should be used when running method.
* @return result of method execution.
* @throws Exception
*/
public static Object execute(String threadKey, Object target,
Method dispatchedMethod, Object[] dispatchedParams)
throws Exception {
if (threadKey == null && target == null && dispatchedMethod == null) {
throw new IllegalArgumentException(
"threadKey, target and the dispatchedMethod must not be null");
}
WorkerThread worker = threadMap.get(threadKey);
if (worker == null) {
throw new DispatchException("No WorkerThread created for ["+ threadKey +"], errored on dispatched method ["+dispatchedMethod.getName()+"]");
}
Object response;
Exchanger exchanger = new Exchanger();
worker.execute(dispatchedMethod, dispatchedParams, target, exchanger);
response = exchanger.exchange(new Object());
if (response instanceof Throwable) {
if(response instanceof InvocationTargetException)
{
/* unwrap target exception */
Exception eActualException = ((InvocationTargetException)response).getCause();
throw new DispatchException("error on dispatched method ["+dispatchedMethod.getName()+"] threw exception ["+eActualException+"]");
}
else
{
throw new DispatchException("error on dispatched method ["+dispatchedMethod.getName()+"] threw exception ["+response+"]");
}
}
return response;
}This won't solve your problem but it will tell you what the actual problem is or at the very least get you one step closer to the real problem (I don't know maybe you will encounter another wrapped exception – there are a number of wrappers and dynamic proxies at play here)
I don't have time to compile, test and build this – it's almost 5am here and I've been up since 8am yesterday – gotta run. I'll commit the change. If you don't have an extension environment or the source base maybe Lennard can fix my syntax errors and hook you up.
Good luck!
-R
