diff --git a/javasource/processqueue/queuehandler/ObjectQueueExecutor.java b/javasource/processqueue/queuehandler/ObjectQueueExecutor.java index ca4f26a..f416eaa 100644 --- a/javasource/processqueue/queuehandler/ObjectQueueExecutor.java +++ b/javasource/processqueue/queuehandler/ObjectQueueExecutor.java @@ -11,7 +11,6 @@ import processqueue.proxies.LogReason; import processqueue.proxies.Process; import processqueue.proxies.QueuedAction; -import processqueue.proxies.microflows.Microflows; import com.mendix.core.Core; import com.mendix.core.CoreException; @@ -67,16 +66,6 @@ public ObjectQueueExecutor( IContext context, IMendixObject action, IMendixObjec this.action = action; this.action.setValue(this.context, QueuedAction.MemberNames.Phase.toString(), ActionStatus.Queued.toString()); - - //Make sure we commit the latest info so status changes always get updated in the client as soon as possible. - // E.g. actions being set to "Queued". - if( this.action.isNew() || this.action.isChanged() ) { - try { - Core.commit( this.context, this.action ); - } catch (CoreException e) { - _logNode.error("Error while trying to commit QueuedAction " + this.action.getValue(this.context, QueuedAction.MemberNames.ActionNumber.toString()) + " from queue", e); - } - } } public void initializeAction(ActionStatus phase, LogExecutionStatus status ) { @@ -152,7 +141,9 @@ public synchronized void run() setErrormessageAndCommit(this.context, this.action, errorMessage, null, LogExecutionStatus.Skipped, ActionStatus.Cancelled ); else { _logNode.info(errorMessage); - Microflows.sUB_ProcessQueue_NoActionFoundErrorHandler(context, errorMessage); + HashMap paramMap = new HashMap(); + paramMap.put("ErrorMessage", errorMessage); + Core.execute(context, "ProcessQueue.SUB_ProcessQueue_NoActionFoundErrorHandler", paramMap); } } else { @@ -309,4 +300,4 @@ public long getActionNr() { public String getMicroflowName() { return this.microflowName; } -} \ No newline at end of file +}