Hi, I have the following simple process having the WSHT 'HumanTask' (Drools Flow 5.1.0.M1) Start Node--> Human Task --> End Node Under the following scenario: a) MinaTaskServer service is started b) Drools Flow Process is started - as it reaches the Human Task ( having 'Wait for completion' as true) - following 4 commands are executed on the mina service i. AddTaskRequest ---> This basically creates the task in the WSHT task tables ii. RegisterForEventRequest --> This is called 3 times to register for following task events (TaskCompletedEvent, TaskFailedEvent, TaskSkippedEvent) c) I guess the above 3 events (b ii) are registered for a callback to the Drools process so that the 'work item' (related to Human Task) state can be properly changed when the above 3 task event occurs - and the drools process can move forward. Now my question is what if the Mina service has to be stopped in between (task has been created but not yet reached the completed status) - then we lose all the registered events (as these are not persistent events) - now when we restart the Mina service we query the task - and let's say we changed the state through "Reserved--> InProgress-->Completed". Now since the registered events are lost, how does the work item will be marked as "completed" (as the associated WSHT task has completed) so that the drools process can move forward - basically end in this case? Any insight will be highly appreciated. Thanks Vijay

Kris, Should I look into the latest snapshot regarding this? Is something already in place or will it be in some future releases? Thanks Vijay -----Original Message----- From: rules-users-bounces(a)lists.jboss.org [mailto:rules-users-bounces@lists.jboss.org] On Behalf Of Kris Verlaenen Sent: Friday, November 13, 2009 10:04 AM To: Rules Users List; Vijay K Pandey Subject: Re: [rules-users] Drools Flow 5.1.0.M1 - Human Task - How to get the WorkItem change state after restart of MinaTaskServer Vijay, The current implementation of the communication between the human task service and the engine is indeed not error-safe. We are currently working on making a more stable communication foundation (where different communication technologies could be used) to solve this issue. Kris Quoting Vijay K Pandey <VPandey(a)mdes.ms.gov&gt;: > Hi, > > I have the following simple process having the WSHT 'HumanTask' > (Drools Flow 5.1.0.M1) > > Start Node--> Human Task --> End Node > > Under the following scenario: > > a) MinaTaskServer service is started > b) Drools Flow Process is started - as it reaches the Human > Task ( having 'Wait for completion' as true) - following 4 commands > are executed on the mina service > i. > AddTaskRequest ---> This basically creates the task in the WSHT task > tables > ii. > RegisterForEventRequest --> This is called 3 times to register for > following task events (TaskCompletedEvent, TaskFailedEvent, > TaskSkippedEvent) > c) I guess the above 3 events (b ii) are registered for a > callback to the Drools process so that the 'work item' (related to > Human Task) state can be properly changed when the above 3 task event > occurs - and the drools process can move forward. > > Now my question is what if the Mina service has to be stopped in > between (task has been created but not yet reached the completed > status) - then we lose all the registered events (as these are not > persistent events) - now when we restart the Mina service we query > the task - and let's say we changed the state through "Reserved--> > InProgress-->Completed". Now since the registered events are lost, > how does the work item will be marked as "completed" (as the > associated WSHT task has completed) so that the drools process can > move forward - basically end in this case? > > Any insight will be highly appreciated. > > Thanks > Vijay > > Disclaimer: http://www.kuleuven.be/cwis/email_disclaimer.htm _______________________________________________ rules-users mailing list rules-users(a)lists.jboss.org https://lists.jboss.org/mailman/listinfo/rules-users _______________________________________________ rules-users mailing list rules-users(a)lists.jboss.org https://lists.jboss.org/mailman/listinfo/rules-users

Hi, We have a web based application that currently deals with MQ Workflow for all the WSHT related processes/tasks. We are in the process of migrating to Drools Flow. In our current scenario we pool MQ workflow session (through apache commons pooling) - and our hundreds of web users use these sessions to get their word done (like starting a new process, retrieving a task, complete/forwarding/terminating tasks etc) - what we have seen is that in an 8hr window we have around 20,000 calls to mq workflow (around 42 calls/minute) - and it scales pretty good with mq workflow session pooling in place. Should I go ahead and extend WSHumanTaskHandler and MinaTaskClient so that they don't go through "connect" on every operation and get the MINA IoSession from some pool - as it might consume quite a bit of resources/time consuming to have a separate physical connections for each operation. Looking forward for your recommendations. Thanks Vijay

Thanks Kris. I did saw the connect method and saw that it only creates a new connection if the client is null, but my question was more at the level of "session" (StatefulKnowledgeSession) and MinaTaskClient creation. StatefulKnowledgeSession ksession = JPAKnowledgeService.newStatefulKnowledgeSession( kbase, null, env ); ksession.getWorkItemManager().registerWorkItemHandler("Human Task", new WSHumanTaskHandler()); So with each StatefulKnowledgeSession - we will have a new "connect". I think pooling the WSHumanTaskHandler would not make any sense bcoz the executeWorkItem method registers the MinaTaskClient with the MinaTaskServer for several events. Now another main component for us is the MinaTaskClient where we will be performing lots of operation where we won't register for any events. In that case I think we can pool the MinaTaskClient - may be even 1 MinaTaskClient can work for all the non registered client operations - as MINA IoSession is thread safe, need to make sure the IoFilter to be thread safe - but to be on better side we can pool MinaTaskClient. I hope I am making some sense? Do let me know your recommendation. Thanks Vijay -----Original Message----- From: rules-users-bounces(a)lists.jboss.org [mailto:rules-users-bounces@lists.jboss.org] On Behalf Of Kris Verlaenen Sent: Sunday, November 15, 2009 1:47 PM To: Rules Users List; Vijay K Pandey Subject: Re: [rules-users] Drools Flow 5.1.0.M1 - Pooling of WSHumanTaskHandler and MinaTaskClient - IoSession One WSHumanTaskHandler should cache the client, so that it does not recreate a new connection every time. Note that, in the connect() method, you only create a new connection if the client is null. Kris Quoting Vijay K Pandey <VPandey(a)mdes.ms.gov&gt;: > Hi, > > We have a web based application that currently deals with MQ Workflow > for all the WSHT related processes/tasks. We are in the process of > migrating to Drools Flow. In our current scenario we pool MQ workflow > session (through apache commons pooling) - and our hundreds of web > users use these sessions to get their word done (like starting a new > process, retrieving a task, complete/forwarding/terminating tasks > etc) - what we have seen is that in an 8hr window we have around > 20,000 calls to mq workflow (around 42 calls/minute) - and it scales > pretty good with mq workflow session pooling in place. > > Should I go ahead and extend WSHumanTaskHandler and MinaTaskClient so > that they don't go through "connect" on every operation and get the > MINA IoSession from some pool - as it might consume quite a bit of > resources/time consuming to have a separate physical connections for > each operation. > > Looking forward for your recommendations. > > Thanks > Vijay > Disclaimer: http://www.kuleuven.be/cwis/email_disclaimer.htm _______________________________________________ rules-users mailing list rules-users(a)lists.jboss.org https://lists.jboss.org/mailman/listinfo/rules-users

I was going through the org.drools.audit.event.LogEvent class and have a question on the following values and what kind of events they relate to - are they related to "Human Task" or something else public static final int BEFORE_TASK_INSTANCE_CREATED = 28; public static final int AFTER_TASK_INSTANCE_CREATED = 29; public static final int BEFORE_TASK_INSTANCE_COMPLETED = 30; public static final int AFTER_TASK_INSTANCE_COMPLETED = 31; Thanks Vijay