[JBoss Portal Users] - Re: How to obtain the current portlet instance?
by ebephil
It took more two afternoons, but I found a solution.
The trick is to use the PortalObjectContainer to obtain the current PortalObject from the current PortalNode.
Anyway, here's my code:
| private Instance getCurrentInstance() {
| PortalNodeImpl node = Navigation.getCurrentNode();
| if (node.getType() != PortalNode.TYPE_WINDOW) {
| return null;
| }
| PortalObjectId id = node.getObjectId();
| Window window = (Window) getPortalObjectContainer().getObject(id);
| PortletContent pc = (PortletContent) window.getContent();
| return getInstanceContainer().getDefinition(pc.getInstanceRef());
| }
|
| @Override
| public boolean writePref(String prefKey, String newPrefValue) {
| Instance currentInstance = getCurrentInstance();
|
| if (null == currentInstance) {
| logger.error("<-- writePref() Current Instance is null, stopping.");
| return false;
| }
|
| try {
| List<PropertyChange> changeList = new ArrayList<PropertyChange>();
| PropertyChange change = PropertyChange.newUpdate(prefKey,
| newPrefValue);
| changeList.add(change);
|
| PropertyChange[] changeArray = changeList
| .toArray(new PropertyChange[changeList.size()]);
|
| logger.info("--> save()", " setting properties");
| currentInstance.setProperties(changeArray);
|
| } catch (PortletInvokerException e) {
| logger.error(e.toString());
| return false;
| } catch (Exception e) {
| logger.error(e.toString());
| return false;
| } catch (Throwable t) {
| logger.error(t.toString());
| return false;
| }
|
| return true;
| }
|
You need to inject the InstanceContainer and PortalObjectContainer via the jboss-portlet.xml:
| <portlet-app>
| ...
| <service>
| <service-name>PortalObjectContainer</service-name>
| <service-class>org.jboss.portal.core.model.portal.PortalObjectContainer</service-class>
| <service-ref>portal:container=PortalObject</service-ref>
| </service>
| <service>
| <service-name>InstanceContainer</service-name>
| <service-class>org.jboss.portal.core.model.instance.InstanceContainer</service-class>
| <service-ref>:container=Instance</service-ref>
| </service>
| ...
| </portlet-app>
|
Then you can access them in your beans, I do it by injecting them via faces-config.xml:
| <faces-config>
| ...
| <managed-bean>
| <managed-bean-name>portletPreferencesHelper</managed-bean-name>
| <managed-bean-class>package.foo.PortletPreferencesHelperJBossImpl</managed-bean-class>
| <managed-bean-scope>session</managed-bean-scope>
| <managed-property>
| <property-name>instanceContainer</property-name>
| <value>#{applicationScope.InstanceContainer}</value>
| </managed-property>
| <managed-property>
| <property-name>portalObjectContainer</property-name>
| <value>#{applicationScope.PortalObjectContainer}</value>
| </managed-property>
| </managed-bean>
| ...
| </faces-config>
|
And now I finally have InstancePreferences capsuled in a Bean. Btw: Reading the PortletPreferences works the usual way. As I never write user-level PortletPreferences, the Portal always falls back to the InstancePreferences.
View the original post : http://www.jboss.org/index.html?module=bb&op=viewtopic&p=4255118#4255118
Reply to the post : http://www.jboss.org/index.html?module=bb&op=posting&mode=reply&p=4255118
15 years, 4 months
[jBPM Users] - Re: workflow design about wait states
by mmusaji
I've added...
| processInstance = executionService.findProcessInstanceById(processInstanceId);
|
| Execution executionInFour = processInstance.findActiveExecutionIn("custom four");
| assertNotNull(executionInFour);
| processInstance = executionService.signalExecutionById(executionInFour.getId());
|
...to my unit test.
Now I'm not getting any exceptions and the output looks like this:
| 15:14:34,393 FIN | [BaseJbpmTestCase] === starting testProcess =============================
| 15:14:34,518 FIN | [BaseJbpmTestCase] using ProcessEngine 78236
| log4j:WARN No appenders could be found for logger (org.hibernate.cfg.Environment).
| log4j:WARN Please initialize the log4j system properly.
| 15:14:35,675 FIN | [ProcessDefinitionImpl] creating new execution for process 'process'
| 15:14:35,675 FIN | [DefaultIdGenerator] generated execution id process.277
| 15:14:35,675 FIN | [ExecuteActivity] executing activity(16408563)
| 15:14:35,675 FIN | [ExecuteActivity] executing activity(custom one)
| Executing
| custom one
| 15:14:35,690 FIN | [Signal] signalling activity(custom one), signalName=null
| 15:14:35,690 FIN | [ExecuteActivity] executing activity(fork)
| 15:14:35,706 FIN | [DefaultIdGenerator] generated execution id process.277.custom two
| 15:14:35,706 FIN | [ExecutionImpl] created execution[process.277.custom two]
| 15:14:35,706 FIN | [JobExecutorMessageSession] sending message ExecuteActivityMessage
| 15:14:35,706 INF | [JobExecutorThread] starting...
| 15:14:35,706 INF | [JobExecutorThread] starting...
| 15:14:35,706 INF | [JobExecutorThread] starting...
| 15:14:35,706 INF | [DispatcherThread] starting...
| 15:14:35,706 FIN | [DefaultIdGenerator] generated execution id process.277.custom three
| 15:14:35,706 FIN | [ExecutionImpl] created execution[process.277.custom three]
| 15:14:35,706 FIN | [JobExecutorMessageSession] sending message ExecuteActivityMessage
| 15:14:35,722 FIN | [AcquireJobsCmd] start querying first acquirable job...
| 15:14:35,722 FIN | [AcquireJobsCmd] locking jobs []
| 15:14:35,722 FIN | [GetNextDueDateCmd] getting next due date...
| 15:14:35,722 FIN | [GetNextDueDateCmd] next due date is null
| 15:14:35,722 FIN | [DispatcherThread] skipped wait because new message arrived
| 15:14:35,722 FIN | [AcquireJobsCmd] start querying first acquirable job...
| 15:14:35,722 FIN | [AcquireJobsCmd] locking jobs [390]
| 15:14:35,722 FIN | [DispatcherThread] pushing jobs on the queue [390]
| 15:14:35,722 FIN | [DispatcherThread] added jobs [390] to the queue
| 15:14:35,722 FIN | [JobExecutorThread] took job(s) [390] from queue
| 15:14:35,722 FIN | [AcquireJobsCmd] start querying first acquirable job...
| 15:14:35,722 FIN | [AcquireJobsCmd] locking jobs [391]
| 15:14:35,722 FIN | [DispatcherThread] pushing jobs on the queue [391]
| 15:14:35,722 FIN | [DispatcherThread] added jobs [391] to the queue
| 15:14:35,722 FIN | [AcquireJobsCmd] start querying first acquirable job...
| 15:14:35,737 FIN | [ExecuteJobCmd] executing job ExecuteActivityMessage[390]...
| 15:14:35,737 FIN | [AcquireJobsCmd] locking jobs []
| 15:14:35,737 FIN | [GetNextDueDateCmd] getting next due date...
| 15:14:35,737 FIN | [GetNextDueDateCmd] next due date is null
| 15:14:35,737 FIN | [DispatcherThread] DispatcherThread will wait for max 600ms on org.jbpm.pvm.internal.jobexecutor.JobExecutor@cd4544
| 15:14:35,737 FIN | [ExecuteJobCmd] executing job ExecuteActivityMessage[390]...
| 15:14:35,784 FIN | [JobExecutorThread] took job(s) [391] from queue
| Executing
| custom two
| Executing
| custom two
| 15:14:35,784 FIN | [ExecuteJobCmd] executing job ExecuteActivityMessage[391]...
| 15:14:35,784 FIN | [ExecuteActivity] execution[process.277.custom two] executes activity(custom two)
| 15:14:35,784 FIN | [JobExecutorMessageSession] sending message ExecuteActivityMessage
| 15:14:35,784 FIN | [ExecuteJobCmd] executed job ExecuteActivityMessage[390]
| 15:14:35,800 FIN | [ExecuteActivity] execution[process.277.custom two] executes activity(custom two)
| 15:14:35,800 FIN | [JobExecutorMessageSession] sending message ExecuteActivityMessage
| 15:14:35,800 FIN | [ExecuteJobCmd] executed job ExecuteActivityMessage[390]
| 15:14:35,800 FIN | [ExecuteActivity] execution[process.277.custom three] executes activity(custom three)
| 15:14:35,800 FIN | [JobExecutorMessageSession] sending message ExecuteActivityMessage
| 15:14:35,800 FIN | [ExecuteJobCmd] executed job ExecuteActivityMessage[391]
| 15:14:35,800 FIN | [DispatcherThread] DispatcherThread woke up
| 15:14:35,800 FIN | [AcquireJobsCmd] start querying first acquirable job...
| Executing
| custom three
| 15:14:35,815 FIN | [AcquireJobsCmd] locking jobs [393, 394]
| 15:14:35,815 FIN | [DispatcherThread] pushing jobs on the queue [393, 394]
| 15:14:35,815 FIN | [DispatcherThread] added jobs [393, 394] to the queue
| 15:14:35,815 FIN | [AcquireJobsCmd] start querying first acquirable job...
| 15:14:35,815 FIN | [AcquireJobsCmd] locking jobs []
| 15:14:35,815 FIN | [JobExecutorThread] took job(s) [393, 394] from queue
| 15:14:35,815 FIN | [GetNextDueDateCmd] getting next due date...
| 15:14:35,815 FIN | [ExecuteJobCmd] executing job ExecuteActivityMessage[393]...
| 15:14:35,815 FIN | [GetNextDueDateCmd] next due date is null
| 15:14:35,815 FIN | [DispatcherThread] DispatcherThread will wait for max 600ms on org.jbpm.pvm.internal.jobexecutor.JobExecutor@cd4544
| 15:14:35,815 FIN | [ExecuteActivity] execution[process.277.custom two] executes activity(join)
| 15:14:35,815 FIN | [ExecuteJobCmd] executed job ExecuteActivityMessage[393]
| 15:14:35,831 FIN | [ExecuteJobCmd] executing job ExecuteActivityMessage[394]...
| 15:14:35,831 FIN | [ExecuteActivity] execution[process.277.custom three] executes activity(join)
| 15:14:35,831 FIN | [ExecutionImpl] execution[process.277.custom two] ends
| 15:14:35,831 FIN | [ExecutionImpl] execution[process.277.custom three] ends
| 15:14:35,831 FIN | [ExecuteActivity] executing activity(custom four)
| Executing
| custom four
| 15:14:35,831 FIN | [ExecuteJobCmd] executed job ExecuteActivityMessage[394]
| 15:14:35,862 FIN | [ExecuteJobCmd] job 390 no longer exists
| 15:14:35,862 FIN | [ExecuteJobCmd] job 391 no longer exists
| 15:14:35,862 FIN | [Signal] signalling activity(custom four), signalName=null
| 15:14:35,862 FIN | [ExecuteActivity] executing activity(end)
| 15:14:35,893 FIN | [DbSessionImpl] deleting history process instance process.277
| 15:14:35,909 FIN | [DbSessionImpl] deleting process instance process.277
| 15:14:35,909 FIN | [DeleteDeploymentCmd] deleting deployment 124
| 15:14:35,940 FIN | [BaseJbpmTestCase] === ending testProcess =============================
|
Still uncertain if my process has ended correctly. Attempting to put this in to my "proper" workflow with more custom nodes is still showing errors.
View the original post : http://www.jboss.org/index.html?module=bb&op=viewtopic&p=4255110#4255110
Reply to the post : http://www.jboss.org/index.html?module=bb&op=posting&mode=reply&p=4255110
15 years, 4 months
[jBPM Users] - Query HistoryService for task assignee and name?
by LMarinkov
I am using jBPM 4.1 and tried to write a unit test that queries the history service using the task assignee and name.
First i looked at the sources of jBPM and searched for tests that are performing a similar query. Unfortunately the only test related to history task assignee was org.jbpm.test.history.HistoryTaskAssigneeTest shown below and the test didn't use the assignee information to perform the query:
/*
| * JBoss, Home of Professional Open Source
| * Copyright 2005, JBoss Inc., and individual contributors as indicated
| * by the @authors tag. See the copyright.txt in the distribution for a
| * full listing of individual contributors.
| *
| * This is free software; you can redistribute it and/or modify it
| * under the terms of the GNU Lesser General Public License as
| * published by the Free Software Foundation; either version 2.1 of
| * the License, or (at your option) any later version.
| *
| * This software is distributed in the hope that it will be useful,
| * but WITHOUT ANY WARRANTY; without even the implied warranty of
| * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
| * Lesser General Public License for more details.
| *
| * You should have received a copy of the GNU Lesser General Public
| * License along with this software; if not, write to the Free
| * Software Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA
| * 02110-1301 USA, or see the FSF site: http://www.fsf.org.
| */
| package org.jbpm.test.history;
|
| import org.jbpm.api.Execution;
| import org.jbpm.api.history.HistoryActivityInstance;
| import org.jbpm.test.JbpmTestCase;
|
|
| /**
| * @author Tom Baeyens
| */
| public class HistoryTaskAssigneeTest extends JbpmTestCase {
|
| public void testHistoryTaskAssignee() {
| deployJpdlXmlString(
| "<process name='TaskAssignee'>" +
| " <start>" +
| " <transition to='review' />" +
| " </start>" +
| " <task name='review' " +
| " assignee='johndoe'>" +
| " <transition to='wait' />" +
| " </task>" +
| " <state name='wait'/>" +
| "</process>"
| );
|
| executionService.startProcessInstanceByKey("TaskAssignee");
|
| HistoryActivityInstance historyActivityInstance = historyService
| .createHistoryActivityInstanceQuery()
| .uniqueResult();
|
| }
|
| }
|
The current implementation of the HistoryTaskQuery allows querying using the assignee but not the name of the task. To find out the name for the task i decided to make a HistoryActivityInstanceQuery using the executiondid that will be delivered by the HistoryTaskQuery. To my surprise this didn't work. The HistoryActivityInstanceQuery delivered 3 HistoryActivityInstances instead of 1. So it is not possible to figure out the name of the task that was performed by the assignee. The unit test is shown below:
package com.cg.wfl.jbpm.examples.wfl_examples.history;
|
| import java.util.List;
|
| import org.jbpm.api.Execution;
| import org.jbpm.api.history.HistoryActivityInstance;
| import org.jbpm.api.history.HistoryTask;
| import org.jbpm.test.JbpmTestCase;
|
| public class HistoryTaskAssigneeTest extends JbpmTestCase {
| public void testHistoryTaskAssignee() {
| deployJpdlXmlString(
| "<process name='TaskAssigneeTest'>" +
| " <start>" +
| " <transition to='a' />" +
| " </start>" +
| " <task name='a' assignee='mary'>" +
| " <transition name='toB' to ='b' />" +
| " </task>" +
| " <task name='b' assignee='alex'>" +
| " <transition name='toC' to ='c' />" +
| " </task>" +
| " <task name='c' assignee='mary'>" +
| " <transition name='toEnd' to ='end' />" +
| " </task>" +
| " <end name='end' />" +
| "</process>"
| );
| Execution execution = executionService.startProcessInstanceByKey("TaskAssigneeTest");
|
| String taskId = taskService.createTaskQuery().uniqueResult().getId();
| taskService.completeTask(taskId);
| taskId = taskService.createTaskQuery().uniqueResult().getId();
| taskService.completeTask(taskId);
| taskId = taskService.createTaskQuery().uniqueResult().getId();
| taskService.completeTask(taskId);
|
| assertNull("execution "+execution.getId()+" should not exist",
| executionService.findExecutionById(execution.getId()));
|
| List<HistoryTask> historyTasks = historyService.createHistoryTaskQuery().
| assignee("mary").list();
| assertEquals(2, historyTasks.size());
|
| historyTasks = historyService.createHistoryTaskQuery().
| assignee("alex").list();
| assertEquals(1, historyTasks.size());
|
| // Try to find out the name of the task for the first task with assignee mary
| String executionId = historyTasks.get(0).getExecutionId();
| List<HistoryActivityInstance> historyActivities = historyService.createHistoryActivityInstanceQuery().
| executionId(executionId).list();
| // The expectation is 1 entry in the list, but the list contains 3 entries
| // It is not possible to link the HistoryTask to the HistoryActivityInstance
| // using the executionId!
| assertEquals(1, historyActivities.size());
| }
| }
|
I found also the following jira issues that references task history details and hope that the problem with the task name will be also considered.
https://jira.jboss.org/jira/browse/JBPM-2442
Any help or comments are welcomed.
View the original post : http://www.jboss.org/index.html?module=bb&op=viewtopic&p=4255107#4255107
Reply to the post : http://www.jboss.org/index.html?module=bb&op=posting&mode=reply&p=4255107
15 years, 4 months
[jBPM Users] - command service
by sravyts
This might be a very easy question to solve , but I can't find the solution (or maybe I'm completely missing the ball here...)
I'm trying to create my own custom query (MyQuery which extends AbstractQuery).
Now is my problem: how can I execute this query?
I was thinking calling processEngine.execute(query) (since AbstractQuery implements the Command interface), but I can't succeed in getting a processEngine (I'm using spring integration)
If I autowire processengine I get the following error:
| Caused by: org.springframework.beans.factory.NoSuchBeanDefinitionException: No unique bean of type [org.jbpm.api.ProcessEngine] is defined: expected single matching bean but found 2: [jbpmConfiguration, processEngine]
|
This is my spring configuration:
| <bean id="jbpmConfiguration" class="org.jbpm.pvm.internal.cfg.SpringConfiguration">
| <constructor-arg value="org/mypackage/jbpm.cfg.xml" />
| </bean>
|
| <bean id="processEngine" factory-bean="jbpmConfiguration" factory-method="buildProcessEngine" />
| <bean id="repositoryService" factory-bean="processEngine" factory-method="getRepositoryService" />
| <bean id="executionService" factory-bean="processEngine" factory-method="getExecutionService" />
| <bean id="historyService" factory-bean="processEngine" factory-method="getHistoryService" />
| <bean id="taskService" factory-bean="processEngine" factory-method="getTaskService" />
| <bean id="identityService" factory-bean="processEngine" factory-method="getIdentityService" />
|
| <bean id="queryExecutor" class="org.mypackage.QueryExecutor" />
|
|
|
And QueryExecutor :
| public class QueryExecutor
| {
| @Autowired
| ProcessEngine processEngine
|
| public List query(MyQuery query){
| return processEngine.execute(query);
| }
| }
|
Is there another way for executing commands using spring integration?
Or aren't we supposed to execute commands?
Wkr,
Sofie
View the original post : http://www.jboss.org/index.html?module=bb&op=viewtopic&p=4255093#4255093
Reply to the post : http://www.jboss.org/index.html?module=bb&op=posting&mode=reply&p=4255093
15 years, 4 months
[jBPM Users] - Re: workflow design about wait states
by mmusaji
Thanks for that Ronald, be a huge help if you can see what I'm doing wrong.
So I changed the async nodes (custom one and two) to takeDefaultTransition().
| package org.workflow.test.forum;
|
| import java.util.List;
| import java.util.Map;
|
| import org.jbpm.api.Execution;
| import org.jbpm.api.ProcessInstance;
| import org.jbpm.api.activity.ActivityExecution;
| import org.jbpm.api.activity.ExternalActivityBehaviour;
| import org.jbpm.api.job.Job;
| import org.jbpm.test.JbpmTestCase;
|
| public class ProcessTest extends JbpmTestCase {
| String deploymentDbid;
|
| protected void setUp() throws Exception {
| super.setUp();
| deploymentDbid = repositoryService.createDeployment()
| .addResourceFromClasspath("org/workflow/test/forum/process.jpdl.xml")
| .deploy();
| }
|
| protected void tearDown() throws Exception {
| repositoryService.deleteDeploymentCascade(deploymentDbid);
| super.tearDown();
| }
|
| public void testProcess() throws Exception {
| ProcessInstance processInstance = executionService.startProcessInstanceByKey("process");
| Execution executionInOne = processInstance.findActiveExecutionIn("custom one");
| assertNotNull(executionInOne);
| processInstance = executionService.signalExecutionById(executionInOne.getId());
|
| String processInstanceId = processInstance.getId();
|
| List<Job> jobs = managementService.createJobQuery()
| .processInstanceId(processInstanceId)
| .list();
|
| assertEquals(2, jobs.size());
|
| Job job = jobs.get(0);
|
| managementService.executeJob(job.getId());
|
| job = jobs.get(1);
|
| managementService.executeJob(job.getId());
|
| Execution executionInFour = processInstance.findActiveExecutionIn("custom four");
| assertNotNull(executionInFour);
| processInstance = executionService.signalExecutionById(executionInFour.getId());
| }
|
| public static class CustomOne implements ExternalActivityBehaviour {
| private static final long serialVersionUID = 1L;
|
| public void execute(ActivityExecution execution) throws Exception {
| System.out.println("Executing");
|
| System.out.println(execution.getActivityName());
|
| execution.waitForSignal();
| }
|
| public void signal(ActivityExecution execution,
| String signalName,
| Map<String, ?> parameters) {
| execution.take(signalName);
| }
| }
|
| public static class CustomTwo implements ExternalActivityBehaviour {
| private static final long serialVersionUID = 1L;
|
| public void execute(ActivityExecution execution) throws Exception {
| System.out.println("Executing");
|
| System.out.println(execution.getActivityName());
|
| execution.takeDefaultTransition();
| }
|
| public void signal(ActivityExecution execution,
| String signalName,
| Map<String, ?> parameters) {
| execution.take(signalName);
| }
| }
|
| public static class CustomThree implements ExternalActivityBehaviour {
| private static final long serialVersionUID = 1L;
|
| public void execute(ActivityExecution execution) throws Exception {
| System.out.println("Executing");
|
| System.out.println(execution.getActivityName());
|
| execution.takeDefaultTransition();
| }
|
| public void signal(ActivityExecution execution,
| String signalName,
| Map<String, ?> parameters) {
| execution.take(signalName);
| }
| }
|
| public static class CustomFour implements ExternalActivityBehaviour {
| private static final long serialVersionUID = 1L;
|
| public void execute(ActivityExecution execution) throws Exception {
| System.out.println("Executing");
|
| System.out.println(execution.getActivityName());
|
| execution.waitForSignal();
| }
|
| public void signal(ActivityExecution execution,
| String signalName,
| Map<String, ?> parameters) {
| execution.take(signalName);
| }
| }
|
| }
|
|
With the same workflow as before I get custom four node as showing output but still get null when the unittest attempts to find execution in this node.
| 13:58:02,975 FIN | [BaseJbpmTestCase] === starting testProcess =============================
| 13:58:03,100 FIN | [BaseJbpmTestCase] using ProcessEngine 22743805
| log4j:WARN No appenders could be found for logger (org.hibernate.cfg.Environment).
| log4j:WARN Please initialize the log4j system properly.
| 13:58:04,288 FIN | [ProcessDefinitionImpl] creating new execution for process 'process'
| 13:58:04,288 FIN | [DefaultIdGenerator] generated execution id process.222
| Executing
| custom one
| 13:58:04,288 FIN | [ExecuteActivity] executing activity(14731203)
| 13:58:04,288 FIN | [ExecuteActivity] executing activity(custom one)
| 13:58:04,303 FIN | [Signal] signalling activity(custom one), signalName=null
| 13:58:04,303 FIN | [ExecuteActivity] executing activity(fork)
| 13:58:04,303 FIN | [DefaultIdGenerator] generated execution id process.222.custom two
| 13:58:04,303 FIN | [ExecutionImpl] created execution[process.222.custom two]
| 13:58:04,319 FIN | [JobExecutorMessageSession] sending message ExecuteActivityMessage
| 13:58:04,319 INF | [JobExecutorThread] starting...
| 13:58:04,319 INF | [JobExecutorThread] starting...
| 13:58:04,319 INF | [JobExecutorThread] starting...
| 13:58:04,319 INF | [DispatcherThread] starting...
| 13:58:04,319 FIN | [DefaultIdGenerator] generated execution id process.222.custom three
| 13:58:04,319 FIN | [ExecutionImpl] created execution[process.222.custom three]
| 13:58:04,319 FIN | [JobExecutorMessageSession] sending message ExecuteActivityMessage
| 13:58:04,319 FIN | [AcquireJobsCmd] start querying first acquirable job...
| 13:58:04,319 FIN | [AcquireJobsCmd] locking jobs []
| 13:58:04,319 FIN | [GetNextDueDateCmd] getting next due date...
| 13:58:04,319 FIN | [GetNextDueDateCmd] next due date is null
| 13:58:04,319 FIN | [DispatcherThread] DispatcherThread will wait for max 600ms on org.jbpm.pvm.internal.jobexecutor.JobExecutor@1ff2e1b
| 13:58:04,319 FIN | [DispatcherThread] DispatcherThread woke up
| 13:58:04,335 FIN | [AcquireJobsCmd] start querying first acquirable job...
| 13:58:04,335 FIN | [AcquireJobsCmd] locking jobs [296]
| 13:58:04,335 FIN | [DispatcherThread] pushing jobs on the queue [296]
| 13:58:04,335 FIN | [DispatcherThread] added jobs [296] to the queue
| 13:58:04,335 FIN | [AcquireJobsCmd] start querying first acquirable job...
| 13:58:04,335 FIN | [AcquireJobsCmd] locking jobs [297]
| 13:58:04,335 FIN | [ExecuteJobCmd] executing job ExecuteActivityMessage[296]...
| 13:58:04,335 FIN | [JobExecutorThread] took job(s) [296] from queue
| 13:58:04,335 FIN | [DispatcherThread] pushing jobs on the queue [297]
| 13:58:04,335 FIN | [DispatcherThread] added jobs [297] to the queue
| 13:58:04,335 FIN | [AcquireJobsCmd] start querying first acquirable job...
| 13:58:04,350 FIN | [AcquireJobsCmd] locking jobs []
| 13:58:04,350 FIN | [GetNextDueDateCmd] getting next due date...
| 13:58:04,350 FIN | [GetNextDueDateCmd] next due date is null
| 13:58:04,350 FIN | [DispatcherThread] DispatcherThread will wait for max 600ms on org.jbpm.pvm.internal.jobexecutor.JobExecutor@1ff2e1b
| Executing
| custom two
| 13:58:04,350 FIN | [ExecuteActivity] execution[process.222.custom two] executes activity(custom two)
| 13:58:04,350 FIN | [JobExecutorThread] took job(s) [297] from queue
| 13:58:04,350 FIN | [JobExecutorMessageSession] sending message ExecuteActivityMessage
| 13:58:04,350 FIN | [ExecuteJobCmd] executing job ExecuteActivityMessage[297]...
| Executing
| custom three
| 13:58:04,350 FIN | [ExecuteJobCmd] executed job ExecuteActivityMessage[296]
| 13:58:04,366 FIN | [ExecuteActivity] execution[process.222.custom three] executes activity(custom three)
| 13:58:04,366 FIN | [JobExecutorMessageSession] sending message ExecuteActivityMessage
| 13:58:04,366 FIN | [ExecuteJobCmd] executed job ExecuteActivityMessage[297]
| 13:58:04,366 FIN | [ExecuteJobCmd] executing job ExecuteActivityMessage[297]...
| 13:58:04,366 FIN | [ExecuteJobCmd] job 296 no longer exists
| Executing
| custom three
| 13:58:04,366 FIN | [DispatcherThread] DispatcherThread woke up
| 13:58:04,366 FIN | [AcquireJobsCmd] start querying first acquirable job...
| 13:58:04,366 FIN | [ExecuteActivity] execution[process.222.custom three] executes activity(custom three)
| 13:58:04,366 FIN | [JobExecutorMessageSession] sending message ExecuteActivityMessage
| 13:58:04,366 FIN | [ExecuteJobCmd] executed job ExecuteActivityMessage[297]
| 13:58:04,381 FIN | [AcquireJobsCmd] locking jobs [298, 299]
| 13:58:04,381 FIN | [DispatcherThread] pushing jobs on the queue [298, 299]
| 13:58:04,381 FIN | [DispatcherThread] added jobs [298, 299] to the queue
| 13:58:04,381 FIN | [JobExecutorThread] took job(s) [298, 299] from queue
| 13:58:04,381 FIN | [AcquireJobsCmd] start querying first acquirable job...
| 13:58:04,381 FIN | [AcquireJobsCmd] locking jobs []
| 13:58:04,381 FIN | [GetNextDueDateCmd] getting next due date...
| 13:58:04,381 FIN | [ExecuteJobCmd] executing job ExecuteActivityMessage[298]...
| 13:58:04,381 FIN | [GetNextDueDateCmd] next due date is null
| 13:58:04,381 FIN | [DispatcherThread] DispatcherThread will wait for max 600ms on org.jbpm.pvm.internal.jobexecutor.JobExecutor@1ff2e1b
| 13:58:04,381 FIN | [ExecuteActivity] execution[process.222.custom two] executes activity(join)
| 13:58:04,381 FIN | [ExecuteJobCmd] executed job ExecuteActivityMessage[298]
| 13:58:04,381 FIN | [ExecuteJobCmd] executing job ExecuteActivityMessage[299]...
| 13:58:04,397 FIN | [ExecuteActivity] execution[process.222.custom three] executes activity(join)
| 13:58:04,397 FIN | [ExecutionImpl] execution[process.222.custom two] ends
| 13:58:04,397 FIN | [ExecutionImpl] execution[process.222.custom three] ends
| 13:58:04,397 FIN | [ExecuteActivity] executing activity(custom four)
| Executing
| custom four
| 13:58:04,397 FIN | [ExecuteJobCmd] executed job ExecuteActivityMessage[299]
| 13:58:04,428 FIN | [ExecuteJobCmd] job 297 no longer exists
| 13:58:04,428 SEV | [BaseJbpmTestCase]
| ### EXCEPTION ###########################################
| 13:58:04,428 SEV | [BaseJbpmTestCase] ASSERTION FAILURE: null
| junit.framework.AssertionFailedError
| at junit.framework.Assert.fail(Assert.java:47)
| at junit.framework.Assert.assertTrue(Assert.java:20)
| at junit.framework.Assert.assertNotNull(Assert.java:220)
| at junit.framework.Assert.assertNotNull(Assert.java:213)
| at org.workflow.test.forum.ProcessTest.testProcess(ProcessTest.java:51)
| at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
| at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:39)
| at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:25)
| at java.lang.reflect.Method.invoke(Method.java:597)
| at junit.framework.TestCase.runTest(TestCase.java:154)
| at org.jbpm.test.BaseJbpmTestCase.runTest(BaseJbpmTestCase.java:80)
| at junit.framework.TestCase.runBare(TestCase.java:127)
| at junit.framework.TestResult$1.protect(TestResult.java:106)
| at junit.framework.TestResult.runProtected(TestResult.java:124)
| at junit.framework.TestResult.run(TestResult.java:109)
| at junit.framework.TestCase.run(TestCase.java:118)
| at junit.framework.TestSuite.runTest(TestSuite.java:208)
| at junit.framework.TestSuite.run(TestSuite.java:203)
| at org.eclipse.jdt.internal.junit.runner.junit3.JUnit3TestReference.run(JUnit3TestReference.java:130)
| at org.eclipse.jdt.internal.junit.runner.TestExecution.run(TestExecution.java:38)
| at org.eclipse.jdt.internal.junit.runner.RemoteTestRunner.runTests(RemoteTestRunner.java:460)
| at org.eclipse.jdt.internal.junit.runner.RemoteTestRunner.runTests(RemoteTestRunner.java:673)
| at org.eclipse.jdt.internal.junit.runner.RemoteTestRunner.run(RemoteTestRunner.java:386)
| at org.eclipse.jdt.internal.junit.runner.RemoteTestRunner.main(RemoteTestRunner.java:196)
| ### EXCEPTION ###########################################
| 13:58:04,428 SEV | [BaseJbpmTestCase]
| 13:58:04,444 FIN | [DbSessionImpl] deleting history process instance process.222
| 13:58:04,460 FIN | [DbSessionImpl] deleting process instance process.222
| 13:58:04,460 FIN | [DeleteDeploymentCmd] deleting deployment 109
| 13:58:04,475 FIN | [BaseJbpmTestCase] === ending testProcess =============================
|
View the original post : http://www.jboss.org/index.html?module=bb&op=viewtopic&p=4255090#4255090
Reply to the post : http://www.jboss.org/index.html?module=bb&op=posting&mode=reply&p=4255090
15 years, 4 months