moparisthebest/jBgJob
1
0
Fork 0
Code Issues Pull Requests Releases 1 Wiki Activity

Make RedisThread throw the error to an ExecutionResult in case RedisErrorQueueThread wants to do something with it

Browse Source
This commit is contained in:
moparisthebest 2013-08-21 14:46:00 -04:00
parent 87a4fd2154
commit ecf55b799c
1 changed files with 9 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
redisprocessor/src/main/java/com/moparisthebest/jbgjob/processor/RedisThread.java
View File

@ -113,9 +113,15 @@ public class RedisThread extends RedisScheduler implements Runnable {
} }
timeoutCounter = 0; timeoutCounter = 0;
if (debug) System.out.println("scheduledItemString: " + scheduledItemString); if (debug) System.out.println("scheduledItemString: " + scheduledItemString);
final ExecutionResult executionResult = getExecutionResult(scheduledItemString);
try{
final ScheduledItem scheduledItem = om.readValue(scheduledItemString, ScheduledItem.class); final ScheduledItem scheduledItem = om.readValue(scheduledItemString, ScheduledItem.class);
if (debug) System.out.println("scheduledItem object: " + scheduledItem); if (debug) System.out.println("scheduledItem object: " + scheduledItem);
executor.execute(scheduledItem, getExecutionResult(scheduledItemString)); executor.execute(scheduledItem, executionResult);
}catch(Throwable e){
if(executionResult != null)
executionResult.error(e);
}
} }
} catch (Throwable e) { } catch (Throwable e) {
e.printStackTrace(); e.printStackTrace();