[jbpm-users] [JBoss jBPM] - Re: Action not executing in timer
I go to sleep in my unit test. I have to give the timer a chance to do its thing. I
suppose I could add a listener to some transition events but they would only fire if
everything is working correctly. Defeats the purpose of the unit test.
If you are saying that I have to manually close a context in order to flush/commit, I
would say that's a very bad design. Sure, while I am in my unit test I have the option
of calling context.close(), a longer running process with various wait states does not
have that luxury. It has to be handled internally by the engine in these cases.
anonymous wrote :
| but in normal cases you do not keep it open and a process goes in a waitstate. You
only open it again if e.g. an external system or person acts on something. ... In most
cases there only is one real thread of execution. Sure, you can have parallel things in
forks, but they seldom act on the same thing at the same time. There are some things being
looked into regarding locks/transactions and a join (see the jira)
|
Yes, and the JobExecutor is this external system that acts on something. Any time you are
using timers, you have multiple threads of execution. Therefore the engine must have some
means of flushing & commit when a timer is created, but it looks to me that it has to
be done manually.
I will open a Jira if you can confirm that some automatic commit/flush does not exist.
BTW, here is my unit test. It works now as long as I commit manually from the main thread.
I get the lock exception if I do not.
| @Test
| public void test() {
| // Create an instance of the order workflow process
| JbpmContext context = _jbpmConfiguration.createJbpmContext();
| final GraphSession graphSession = context.getGraphSession();
| final ProcessDefinition process =
graphSession.findLatestProcessDefinition("examplePause");
| ProcessInstance processInstance = process.createProcessInstance();
|
| // Kick off the process
| Token token = processInstance.getRootToken();
| token.signal();
|
| Assert.assertEquals(token.getNode().getName(), "state1");
|
| // Force the timer task to be committed (Note: this is where I don't
understand
| // why this is a manual step. If this was running outside of a unit test,
| // Where would this commit go?
| context.close();
|
| // Sleep. Timer should fire within 10 seconds. At wakeup, we should be in the
end node.
| try {
| Thread.sleep(15000);
| } catch (InterruptedException e) {
| e.printStackTrace();
| }
|
| // note the need to recreate the context and refetch the token...
| context = _jbpmConfiguration.createJbpmContext();
| token = context.getToken(token.getId());
|
| Assert.assertEquals(token.getNode().getName(), "endPauseExample");
| }
|
Thanks Ronald for your assistance throughout this process. Seems like you are a one-man
show. :)
View the original post :
http://www.jboss.com/index.html?module=bb&op=viewtopic&p=4181727#...
Reply to the post :
http://www.jboss.com/index.html?module=bb&op=posting&mode=reply&a...