1 25 package org.ofbiz.workflow.client; 26 27 import java.util.Date ; 28 import java.util.HashMap ; 29 30 import org.ofbiz.base.util.Debug; 31 import org.ofbiz.service.GenericRequester; 32 import org.ofbiz.service.job.AbstractJob; 33 import org.ofbiz.workflow.WfActivity; 34 35 42 public class StartActivityJob extends AbstractJob { 43 44 public static final String module = StartActivityJob.class.getName(); 45 46 protected WfActivity activity = null; 47 protected GenericRequester requester = null; 48 49 public StartActivityJob(WfActivity activity) { 50 this(activity, null); 51 } 52 53 public StartActivityJob(WfActivity activity, GenericRequester requester) { 54 super(activity.toString() + "." + System.currentTimeMillis(), activity.toString()); 55 this.activity = activity; 56 this.requester = requester; 57 runtime = new Date ().getTime(); 58 if (Debug.verboseOn()) Debug.logVerbose("Created new StartActivityJob : " + activity, module); 59 } 60 61 protected void finish() { 62 runtime = -1; 63 } 64 65 68 public void exec() { 69 String activityIds = null; 70 try { 71 Debug.logVerbose("Executing job now : " + activity, module); 72 activity.activate(); 73 if (requester != null) 74 requester.receiveResult(new HashMap ()); 75 } catch (Exception e) { 76 Debug.logError(e, "Start Activity [" + activity + "] Failed", module); 77 if (requester != null) 78 requester.receiveThrowable(e); 79 } 80 finish(); 81 } 82 } 83 | Popular Tags |