You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@ofbiz.apache.org by ja...@apache.org on 2007/12/18 19:46:03 UTC
svn commit: r605290 - in
/ofbiz/trunk/framework/service/src/org/ofbiz/service/job: JobInvoker.java
JobManager.java JobPoller.java
Author: jaz
Date: Tue Dec 18 10:46:02 2007
New Revision: 605290
URL: http://svn.apache.org/viewvc?rev=605290&view=rev
Log:
added initial status when using the schedule() method; changed wait() to sleep() in invoker
Modified:
ofbiz/trunk/framework/service/src/org/ofbiz/service/job/JobInvoker.java
ofbiz/trunk/framework/service/src/org/ofbiz/service/job/JobManager.java
ofbiz/trunk/framework/service/src/org/ofbiz/service/job/JobPoller.java
Modified: ofbiz/trunk/framework/service/src/org/ofbiz/service/job/JobInvoker.java
URL: http://svn.apache.org/viewvc/ofbiz/trunk/framework/service/src/org/ofbiz/service/job/JobInvoker.java?rev=605290&r1=605289&r2=605290&view=diff
==============================================================================
--- ofbiz/trunk/framework/service/src/org/ofbiz/service/job/JobInvoker.java (original)
+++ ofbiz/trunk/framework/service/src/org/ofbiz/service/job/JobInvoker.java Tue Dec 18 10:46:02 2007
@@ -210,7 +210,7 @@
if (job == null) {
try {
- wait(wait);
+ java.lang.Thread.sleep(wait);
} catch (InterruptedException ie) {
Debug.logError(ie, "JobInvoker.run() : InterruptedException", module);
stop();
Modified: ofbiz/trunk/framework/service/src/org/ofbiz/service/job/JobManager.java
URL: http://svn.apache.org/viewvc/ofbiz/trunk/framework/service/src/org/ofbiz/service/job/JobManager.java?rev=605290&r1=605289&r2=605290&view=diff
==============================================================================
--- ofbiz/trunk/framework/service/src/org/ofbiz/service/job/JobManager.java (original)
+++ ofbiz/trunk/framework/service/src/org/ofbiz/service/job/JobManager.java Tue Dec 18 10:46:02 2007
@@ -398,7 +398,7 @@
jobName = Long.toString((new Date().getTime()));
}
Map<String, Object> jFields = UtilMisc.<String, Object>toMap("jobName", jobName, "runTime", new java.sql.Timestamp(startTime),
- "serviceName", serviceName, "recurrenceInfoId", infoId, "runtimeDataId", dataId);
+ "serviceName", serviceName, "statusId", "SERVICE_PENDING", "recurrenceInfoId", infoId, "runtimeDataId", dataId);
// set the pool ID
if (poolName != null && poolName.length() > 0) {
@@ -414,7 +414,7 @@
jFields.put("maxRetry", Long.valueOf(maxRetry));
// create the value and store
- GenericValue jobV = null;
+ GenericValue jobV;
try {
jobV = delegator.makeValue("JobSandbox", jFields);
delegator.createSetNextSeqId(jobV);
Modified: ofbiz/trunk/framework/service/src/org/ofbiz/service/job/JobPoller.java
URL: http://svn.apache.org/viewvc/ofbiz/trunk/framework/service/src/org/ofbiz/service/job/JobPoller.java?rev=605290&r1=605289&r2=605290&view=diff
==============================================================================
--- ofbiz/trunk/framework/service/src/org/ofbiz/service/job/JobPoller.java (original)
+++ ofbiz/trunk/framework/service/src/org/ofbiz/service/job/JobPoller.java Tue Dec 18 10:46:02 2007
@@ -88,10 +88,12 @@
try {
// grab a list of jobs to run.
List<Job> pollList = jm.poll();
+ //Debug.logInfo("Received poll list from JobManager [" + pollList.size() + "]", module);
for (Job job : pollList) {
if (job.isValid()) {
queueNow(job);
+ //Debug.logInfo("Job [" + job.getJobId() + "] is queued", module);
}
}
// NOTE: using sleep instead of wait for stricter locking