jboss-user
[Arriba] [Todas las Listas]

[jboss-Usuario] [jBPM] - jBPM el asunto que utiliza Persistencia y fireU

To: User development <jboss-user@xxxxxxxxxxxxxxx>
Subject: [jboss-Usuario] [jBPM] - jBPM el asunto que utiliza Persistencia y fireUntilHalt
From: Abhishek Chavan <do-not-reply@xxxxxxxxx>
Date: Wed, 07 Sep 2011 03:16:47 -0400
Auto-submitted: yes
Delivery-date: Wed, 07 Sep 2011 03:33:10 -0400
Envelope-to: traductor@xxxxxxxxxxx
List-archive: <http://lists.jboss.org/pipermail/jboss-user>
List-help: <mailto:jboss-user-request@lists.jboss.org?subject=help>
List-id: The JBoss User main mailing list <jboss-user.lists.jboss.org>
List-post: <mailto:jboss-user@lists.jboss.org>
List-subscribe: <https://lists.jboss.org/mailman/listinfo/jboss-user>, <mailto:jboss-user-request@lists.jboss.org?subject=subscribe>
List-unsubscribe: <https://lists.jboss.org/mailman/listinfo/jboss-user>, <mailto:jboss-user-request@lists.jboss.org?subject=unsubscribe>
Reply-to: The JBoss User main mailing list <jboss-user@xxxxxxxxxxxxxxx>
Sender: jboss-user-bounces@xxxxxxxxxxxxxxx
*Abhishek *Chavan [*http://Comunidad.*jboss.*org/Personas/*bezudar] creó la discusión

"*jBPM emite utilizar Persistencia y *fireUntilHalt"

para ver la discusión, visita: *http://comunidad.*jboss.*org/Mensaje/625191#625191

--------------------------------------------------------------
*Hi,
estoy intentando utilizar el *jBPM ejemplo para persistir el dato e intentando utilizar otro hilo para la regla que procesa utilizando 
*ksession.*fireUntilHalt();

Pero estoy encontrando el siguiendo excepción.
Excepción en Hilo "de hilo-4" *org.*drools.*RuntimeDroolsException: La Excepción inesperada que ejecuta acción *org.*jbpm.Proceso.Caso.Acontecimiento.*DefaultSignalManager$*SignalAction@1ser20*c
    en *org.*drools.Común.*AbstractWorkingMemory.*executeQueuedActions(*AbstractWorkingMemory.*java:996)
    en *org.*drools.Común.*DefaultAgenda.*fireUntilHalt(*DefaultAgenda.*java:1037)
    en *org.*drools.Común.*AbstractWorkingMemory.*fireUntilHalt(*AbstractWorkingMemory.*java:777)
    en *org.*drools.Común.*AbstractWorkingMemory.*fireUntilHalt(*AbstractWorkingMemory.*java:753)
    en *org.*drools.Orden.*runtime.Regla.*FireUntilHaltCommand$1.Carrera(*FireUntilHaltCommand.*java:50)
    en *java.*lang.Hilo.Carrera(*Unknown Fuente)
Causado por: *java.*lang.*NullPointerException
    En *org.*drools.Persistencia.*jpa.*processinstance.*JPAWorkItemManager.*internalExecuteWorkItem(*JPAWorkItemManager.*java:43)
    en *org.*jbpm.*workflow.Caso.Nodo.*WorkItemNodeInstance.*internalTrigger(*WorkItemNodeInstance.*java:106)
    en *org.*jbpm.*workflow.Caso.*impl.*NodeInstanceImpl.Gatillo(*NodeInstanceImpl.*java:122)
    en *org.*jbpm.*workflow.Caso.*impl.*NodeInstanceImpl.*triggerConnection(*NodeInstanceImpl.*java:186)
    en *org.*jbpm.*workflow.Caso.*impl.*NodeInstanceImpl.*triggerCompleted(*NodeInstanceImpl.*java:150)
    en *org.*jbpm.*workflow.Caso.*impl.*ExtendedNodeInstanceImpl.*triggerCompleted(*ExtendedNodeInstanceImpl.*java:47)
    en *org.*jbpm.*workflow.Caso.Nodo.*StateBasedNodeInstance.*triggerCompleted(*StateBasedNodeInstance.*java:162)
    en *org.*jbpm.*workflow.Caso.Nodo.*StateBasedNodeInstance.*triggerCompleted(*StateBasedNodeInstance.*java:143)
    en *org.*jbpm.*workflow.Caso.Nodo.*RuleSetNodeInstance.*signalEvent(*RuleSetNodeInstance.*java:73)
    en *org.*jbpm.*workflow.Caso.*impl.*WorkflowProcessInstanceImpl.*signalEvent(*WorkflowProcessInstanceImpl.*java:339)
    en *org.*jbpm.Proceso.Caso.Acontecimiento.*DefaultSignalManager.*internalSignalEvent(*DefaultSignalManager.*java:80)
    en *org.*jbpm.Proceso.Caso.Acontecimiento.*DefaultSignalManager$*SignalAction.Ejecuta(*DefaultSignalManager.*java:175)
    en *org.*drools.Común.*AbstractWorkingMemory.*executeQueuedActions(*AbstractWorkingMemory.*java:994)
    ... 5 más


Igual está trabajando bien sin la persistencia y otra prueba está corriendo bien con persistencia pero allí *i estoy llamando 
*kession.*fireAllRules();

 Explícitamente. He hecho mis clases de modelo *serializable.

El código utilizado es :
público *void *reactiveProcessAndRulesTest() echa *InterruptedException
        #unknown{^*KnowledgeBuilder *kbuilder = *KnowledgeBuilderFactory
                .*newKnowledgeBuilder();
        *kbuilder.Añade(nuevo *ClassPathResource("*EmergencyServiceSimple.*bpmn"),
                *ResourceType.*BPMN2);
        *kbuilder.Añade(nuevo *ClassPathResource("*SelectEmergencyVehicleSimple.*drl"),
                *ResourceType.DRL);
        *KnowledgeBuilderErrors errores = *kbuilder.*getErrors();
        Si (errores.Medida() > 0)
            #cnj (*KnowledgeBuilderError error : errores)
                #nom.Fuera.*println(Error.*getMessage());
 
            }
            Regreso;
        }
 
        *KnowledgeBase *kbase = *KnowledgeBaseFactory.*newKnowledgeBase();
        *kbase.*addKnowledgePackages(*kbuilder.*getKnowledgePackages());
 
        *EntityManagerFactory *emf = Persistencia
                .*createEntityManagerFactory("*org.*jbpm.Tarea");
        Entorno *env = *KnowledgeBaseFactory.*newEnvironment();
        *env.Conjunto(*EnvironmentName.FÁBRICA_de DIRECTOR_de la ENTIDAD, *emf);
 
        final *StatefulKnowledgeSession *ksession = *JPAKnowledgeService
                .*newStatefulKnowledgeSession(*kbase, *null, *env);
//         *ksession = *kbase.*newStatefulKnowledgeSession();
 
        // Poniendo el motor de proceso y el motor de regla en *reactive modo
        // Esto causará que si una regla es *activated, la regla disparará
        // sin esperar
        // el usuario para llamar el *fireAllRules() método.
        
 
        *MyHumanChangingValuesSimulatorWorkItemHandler *humanActivitiesSimHandler = Nuevo *MyHumanChangingValuesSimulatorWorkItemHandler();
        *ksession.*getWorkItemManager().*registerWorkItemHandler("Tarea humana",
                *humanActivitiesSimHandler);
 
        *KnowledgeRuntimeLoggerFactory.*newConsoleLogger(*ksession);
 
        Emergencia de emergencia = Emergencia nueva("555-1234");
        // Corrido con Ataque de Corazón y comprobar la producción. Una Ambulancia tiene que aparecer
        // en la emergencia
        // de informe.*setType("Ataque de corazón");
        // Corrido con Fuego y comprobar la producción. Un *FireTruck tiene que aparecer en
        la // emergencia
        de informe.*setType("Fuego");
        Cadena<de Mapa, parámetros> de Objeto = nuevos *HashMap<Cadena, Objeto>();
        parámetros.Puesto("emergencia", emergencia);
 
        *WorkflowProcessInstance proceso = (*WorkflowProcessInstance) *ksession
                .*startProcess(
                        "*com.*wordpress.*salaboy.*bpmn2.*SimpleEmergencyService",
                        parámetros);
        // Mi Emergencia y Mi Proceso son ambos insertado como Verdades / de Hechos en mi
        // Sesión de Conocimiento
        // Ahora la Emergencia y el Caso de Proceso pueden ser utilizados por el *inference
        // motor
        *ksession.Inserta(emergencia);
        *ksession.Inserta(proceso);
        
        Hilo nuevo(nuevo *Runnable()
 
            #adj *void carrera()
                
                #unknown{^*ksession.*fireUntilHalt();
            }
        }).Inicio();
 
        // Es el Proceso todavía Activo?
        *Assert.*assertEquals(*ProcessInstance.ESTATAL_ACTIVO, proceso.*getState());
        // Es allí un corriendo caso de nodo?
        *Assert.*assertEquals(1, proceso.*getNodeInstances().Medida());
        // Es el proceso parado en "el Pedir actividad de Información"
        // de la Emergencia?
        *Assert.*assertEquals("Pide Información de Emergencia", proceso
                .*getNodeInstances().*iterator().Próximo().*getNodeName());
        // Deja comprueba el valor de la emergencia.*getRevision(), tendría que ser 1
        *Assert.*assertEquals(1,
                ((Emergencia) proceso.*getVariable("Emergencia")).*getRevision());
 
        Sistema.Fuera.*println("Completando la primera Actividad");
        // Completo la primera actividad humana
        *humanActivitiesSimHandler.*completeWorkItem();
 
        // Necesito dormir para un poco mientras, porque el otro hilo puede ser
        ejecutar algunos *activated Hilo
        de reglas.Sueño(1000);
 
        // Deja comprueba el valor de la variable de vehículo tendría que ser un Fuego
        // de Camión => del Fuego
        *Assert.*assertTrue(((Vehículo) proceso.*getVariable("Vehículo")) *instanceof *FireTruck);
 
        // Es el Proceso todavía Activo?
        *Assert.*assertEquals(*ProcessInstance.ESTATAL_ACTIVO, proceso.*getState());
        // Es allí un corriendo caso de nodo?
        *Assert.*assertEquals(1, proceso.*getNodeInstances().Medida());
        // Es el proceso parado en "la actividad de Vehículo" del Despacho?
        *Assert.*assertEquals("Vehículo de despacho", proceso.*getNodeInstances()
                .*iterator().Próximo().*getNodeName());
        // Deja comprueba el valor de la emergencia.*getRevision(), tendría que ser 2
        *Assert.*assertEquals(2,
                ((Emergencia) proceso.*getVariable("Emergencia")).*getRevision());
 
        Sistema.Fuera.*println("Completando la segunda Actividad");
        // Completo la segunda actividad humana
        *humanActivitiesSimHandler.*completeWorkItem();
 
        // Es el proceso completó?
        *Assert.*assertEquals(*ProcessInstance.ESTATAL_COMPLETADO, proceso.*getState());
    }
 
 


Mi código Lleno es en este hilo :  *http://comunidad.*jboss.*org/Mensaje/625081#625081 *http://comunidad.*jboss.*org/Mensaje/625081

Cualquier ayuda sería apreciada. 

También veo muy *wierd el comportamiento que pasa cuándo corriendo el programa en Depurar modo en *eclipse y modo corrido.
--------------------------------------------------------------

Respuesta a este mensaje por ir a Comunidad
[*http://comunidad.*jboss.*org/Mensaje/625191#625191]

Empieza una discusión nueva en *jBPM en Comunidad
[*http://comunidad.*jboss.*org/Escoge-contenedor!Entrada.*jspa?*contentType=1&*containerType=14&contenedor=2034]

Abhishek Chavan [http://community.jboss.org/people/bezudar] created the discussion

"jBPM issue using Persistence and fireUntilHalt"

To view the discussion, visit: http://community.jboss.org/message/625191#625191

--------------------------------------------------------------
Hi,
I am trying to use the jBPM example for persisting the data and trying to use another thread for rule processing using 
ksession.fireUntilHalt();

but I am encountering the following exception.
Exception in thread "Thread-4" org.drools.RuntimeDroolsException: Unexpected exception executing action org.jbpm.process.instance.event.DefaultSignalManager$SignalAction@1be20c
    at org.drools.common.AbstractWorkingMemory.executeQueuedActions(AbstractWorkingMemory.java:996)
    at org.drools.common.DefaultAgenda.fireUntilHalt(DefaultAgenda.java:1037)
    at org.drools.common.AbstractWorkingMemory.fireUntilHalt(AbstractWorkingMemory.java:777)
    at org.drools.common.AbstractWorkingMemory.fireUntilHalt(AbstractWorkingMemory.java:753)
    at org.drools.command.runtime.rule.FireUntilHaltCommand$1.run(FireUntilHaltCommand.java:50)
    at java.lang.Thread.run(Unknown Source)
Caused by: java.lang.NullPointerException
    at org.drools.persistence.jpa.processinstance.JPAWorkItemManager.internalExecuteWorkItem(JPAWorkItemManager.java:43)
    at org.jbpm.workflow.instance.node.WorkItemNodeInstance.internalTrigger(WorkItemNodeInstance.java:106)
    at org.jbpm.workflow.instance.impl.NodeInstanceImpl.trigger(NodeInstanceImpl.java:122)
    at org.jbpm.workflow.instance.impl.NodeInstanceImpl.triggerConnection(NodeInstanceImpl.java:186)
    at org.jbpm.workflow.instance.impl.NodeInstanceImpl.triggerCompleted(NodeInstanceImpl.java:150)
    at org.jbpm.workflow.instance.impl.ExtendedNodeInstanceImpl.triggerCompleted(ExtendedNodeInstanceImpl.java:47)
    at org.jbpm.workflow.instance.node.StateBasedNodeInstance.triggerCompleted(StateBasedNodeInstance.java:162)
    at org.jbpm.workflow.instance.node.StateBasedNodeInstance.triggerCompleted(StateBasedNodeInstance.java:143)
    at org.jbpm.workflow.instance.node.RuleSetNodeInstance.signalEvent(RuleSetNodeInstance.java:73)
    at org.jbpm.workflow.instance.impl.WorkflowProcessInstanceImpl.signalEvent(WorkflowProcessInstanceImpl.java:339)
    at org.jbpm.process.instance.event.DefaultSignalManager.internalSignalEvent(DefaultSignalManager.java:80)
    at org.jbpm.process.instance.event.DefaultSignalManager$SignalAction.execute(DefaultSignalManager.java:175)
    at org.drools.common.AbstractWorkingMemory.executeQueuedActions(AbstractWorkingMemory.java:994)
    ... 5 more


The same is working fine without persistence and another test is running fine with persistence but there i am calling 
kession.fireAllRules();

 explicitly. I have made my model classes serializable.

The code used is :
public void reactiveProcessAndRulesTest() throws InterruptedException {
        KnowledgeBuilder kbuilder = KnowledgeBuilderFactory
                .newKnowledgeBuilder();
        kbuilder.add(new ClassPathResource("EmergencyServiceSimple.bpmn"),
                ResourceType.BPMN2);
        kbuilder.add(new ClassPathResource("SelectEmergencyVehicleSimple.drl"),
                ResourceType.DRL);
        KnowledgeBuilderErrors errors = kbuilder.getErrors();
        if (errors.size() > 0) {
            for (KnowledgeBuilderError error : errors) {
                System.out.println(error.getMessage());
 
            }
            return;
        }
 
        KnowledgeBase kbase = KnowledgeBaseFactory.newKnowledgeBase();
        kbase.addKnowledgePackages(kbuilder.getKnowledgePackages());
 
        EntityManagerFactory emf = Persistence
                .createEntityManagerFactory("org.jbpm.task");
        Environment env = KnowledgeBaseFactory.newEnvironment();
        env.set(EnvironmentName.ENTITY_MANAGER_FACTORY, emf);
 
        final StatefulKnowledgeSession ksession = JPAKnowledgeService
                .newStatefulKnowledgeSession(kbase, null, env);
//         ksession = kbase.newStatefulKnowledgeSession();
 
        // Setting the process engine and the rule engine in reactive mode
        // This will cause that if a rule is activated, the rule will fire
        // without waiting
        // the user to call the fireAllRules() method.
        
 
        MyHumanChangingValuesSimulatorWorkItemHandler humanActivitiesSimHandler = new MyHumanChangingValuesSimulatorWorkItemHandler();
        ksession.getWorkItemManager().registerWorkItemHandler("Human Task",
                humanActivitiesSimHandler);
 
        KnowledgeRuntimeLoggerFactory.newConsoleLogger(ksession);
 
        Emergency emergency = new Emergency("555-1234");
        // Run with Heart Attack and check the output. An Ambulance must appear
        // in the report
        // emergency.setType("Heart Attack");
        // Run with Fire and check the output. A FireTruck must appear in the
        // report
        emergency.setType("Fire");
        Map<String, Object> parameters = new HashMap<String, Object>();
        parameters.put("emergency", emergency);
 
        WorkflowProcessInstance process = (WorkflowProcessInstance) ksession
                .startProcess(
                        "com.wordpress.salaboy.bpmn2.SimpleEmergencyService",
                        parameters);
        // My Emergency and My Process are both inserted as Facts / Truths in my
        // Knowledge Session
        // Now Emergency and the Process Instance can be used by the inference
        // engine
        ksession.insert(emergency);
        ksession.insert(process);
        
        new Thread(new Runnable() {
 
            public void run() {
                
                ksession.fireUntilHalt();
            }
        }).start();
 
        // Is the Process still Active?
        Assert.assertEquals(ProcessInstance.STATE_ACTIVE, process.getState());
        // Is there a running node instance?
        Assert.assertEquals(1, process.getNodeInstances().size());
        // Is the process stopped in the "Ask for Emergency Information"
        // activity?
        Assert.assertEquals("Ask for Emergency Information", process
                .getNodeInstances().iterator().next().getNodeName());
        // Lets check the value of the emergency.getRevision(), it should be 1
        Assert.assertEquals(1,
                ((Emergency) process.getVariable("emergency")).getRevision());
 
        System.out.println("Completing the first Activity");
        // Complete the first human activity
        humanActivitiesSimHandler.completeWorkItem();
 
        // I need to sleep for a little while, because the other thread can be
        // executing some activated rules
        Thread.sleep(1000);
 
        // Lets check the value of the vehicle variable it should be a Fire
        // Truck => Fire
        Assert.assertTrue(((Vehicle) process.getVariable("vehicle")) instanceof FireTruck);
 
        // Is the Process still Active?
        Assert.assertEquals(ProcessInstance.STATE_ACTIVE, process.getState());
        // Is there a running node instance?
        Assert.assertEquals(1, process.getNodeInstances().size());
        // Is the process stopped in the "Dispatch Vehicle" activity?
        Assert.assertEquals("Dispatch Vehicle", process.getNodeInstances()
                .iterator().next().getNodeName());
        // Lets check the value of the emergency.getRevision(), it should be 2
        Assert.assertEquals(2,
                ((Emergency) process.getVariable("emergency")).getRevision());
 
        System.out.println("Completing the second Activity");
        // Complete the second human activity
        humanActivitiesSimHandler.completeWorkItem();
 
        // Is the process completed?
        Assert.assertEquals(ProcessInstance.STATE_COMPLETED, process.getState());
    }
 
 


My Full code is in this thread :  http://community.jboss.org/message/625081#625081 http://community.jboss.org/message/625081

Any help would be appreciated. 

I also see very wierd behaviour happening when running the program in Debug mode in eclipse and run mode.
--------------------------------------------------------------

Reply to this message by going to Community
[http://community.jboss.org/message/625191#625191]

Start a new discussion in jBPM at Community
[http://community.jboss.org/choose-container!input.jspa?contentType=1&containerType=14&container=2034]

_______________________________________________
*jboss-Usuario *mailing lista
*jboss-user@xxxxxxxxxxxxxxx
*https://listas.*jboss.*org/*mailman/*listinfo/*jboss-Usuario
_______________________________________________
jboss-user mailing list
jboss-user@xxxxxxxxxxxxxxx
https://lists.jboss.org/mailman/listinfo/jboss-user
<Anterior por Tema] Tema Actual [Siguiente por Tema>
  • [jboss-Usuario] [jBPM] - jBPM el asunto que utiliza Persistencia y fireUntilHalt, Abhishek Chavan <=