Package org.drools.command

Examples of org.drools.command.SingleSessionCommandService.execute()


        service.dispose();

        service = jpaService.loadStatefulKnowledgeSession(sessionId);
        getProcessInstanceCommand = new GetProcessInstanceCommand();
        getProcessInstanceCommand.setProcessInstanceId( subProcessInstanceId );
        subProcessInstance = (RuleFlowProcessInstance) service.execute( getProcessInstanceCommand );
        assertNull( subProcessInstance );

        getProcessInstanceCommand = new GetProcessInstanceCommand();
        getProcessInstanceCommand.setProcessInstanceId( processInstanceId );
        processInstance = (RuleFlowProcessInstance) service.execute( getProcessInstanceCommand );
View Full Code Here


        subProcessInstance = (RuleFlowProcessInstance) service.execute( getProcessInstanceCommand );
        assertNull( subProcessInstance );

        getProcessInstanceCommand = new GetProcessInstanceCommand();
        getProcessInstanceCommand.setProcessInstanceId( processInstanceId );
        processInstance = (RuleFlowProcessInstance) service.execute( getProcessInstanceCommand );
        assertNull( processInstance );
        service.dispose();
    }

    private static Package getProcessSubProcess() {
View Full Code Here

        int sessionId = service.getSessionId();
        log.info("---> created SingleSessionCommandService id: " + sessionId);
           
        StartProcessCommand startProcessCommand = new StartProcessCommand();
        startProcessCommand.setProcessId( "org.drools.test.ProcessTimer" );
        ProcessInstance processInstance = service.execute( startProcessCommand );
        long procId = processInstance.getId();
    log.info( "---> Started ProcessTimer id: {}", procId );
        service.dispose();
        log.info( "---> session disposed" );
View Full Code Here

        service = jpaService.loadStatefulKnowledgeSession(sessionId);
        log.info( "---> load session: " + sessionId);
        GetProcessInstanceCommand getProcessInstanceCommand = new GetProcessInstanceCommand();
        getProcessInstanceCommand.setProcessInstanceId( procId );
        processInstance = service.execute( getProcessInstanceCommand );
        log.info("---> GetProcessInstanceCommand id: " + procId);
        assertNotNull( processInstance );
        log.info( "---> session disposed" );
        service.dispose();
View Full Code Here

        log.info( "---> load session: " + sessionId);
        Thread.sleep( 3000 );
        getProcessInstanceCommand = new GetProcessInstanceCommand();
        getProcessInstanceCommand.setProcessInstanceId( procId );
        log.info("---> GetProcessInstanceCommand id: " + procId);
        processInstance = service.execute( getProcessInstanceCommand );
        log.info( "---> session disposed" );
        assertNull( processInstance );
    }

    private static Package getProcessTimer() {
View Full Code Here

        int sessionId = service.getSessionId();
       
        StartProcessCommand startProcessCommand = new StartProcessCommand();
        startProcessCommand.setProcessId( "org.drools.test.ProcessTimer2" );
        ProcessInstance processInstance = service.execute( startProcessCommand );
        log.info( "Started process instance {}", processInstance.getId() );

        Thread.sleep( 2000 );

        service = jpaService.loadStatefulKnowledgeSession(sessionId);
View Full Code Here

        Thread.sleep( 2000 );

        service = jpaService.loadStatefulKnowledgeSession(sessionId);
        GetProcessInstanceCommand getProcessInstanceCommand = new GetProcessInstanceCommand();
        getProcessInstanceCommand.setProcessInstanceId( processInstance.getId() );
        processInstance = service.execute( getProcessInstanceCommand );
        assertNull( processInstance );
    }

    private static Package getProcessTimer2() {
        RuleFlowProcess process = new RuleFlowProcess();
View Full Code Here

        parameters.put("y", new MyEntity("This is a test Entity with annotation in fields"));
        parameters.put("m", new MyEntityMethods("This is a test Entity with annotations in methods"));
        parameters.put("f", new MyEntityOnlyFields("This is a test Entity with annotations in fields and without accesors methods"));
        parameters.put("z", new MyVariableSerializable("This is a test SerializableObject"));
        startProcessCommand.setParameters(parameters);
        WorkflowProcessInstance processInstance = (WorkflowProcessInstance) service.execute( startProcessCommand );
        log.info( "Started process instance {}", processInstance.getId() );
   
        TestWorkItemHandler handler = TestWorkItemHandler.getInstance();
        WorkItem workItem = handler.getWorkItem();
        assertNotNull( workItem );
View Full Code Here

        log.info("### Retrieving process instance ###");
       
        service = jpaService.loadStatefulKnowledgeSession(sessionId);
        GetProcessInstanceCommand getProcessInstanceCommand = new GetProcessInstanceCommand();
        getProcessInstanceCommand.setProcessInstanceId( processInstance.getId() );
        processInstance = (WorkflowProcessInstance) service.execute( getProcessInstanceCommand );
        assertNotNull( processInstance );
       
        assertNotNull( processInstance );
        assertEquals("SomeString", processInstance.getVariable("x"));
        assertEquals("This is a test Entity with annotation in fields", ((MyEntity) processInstance.getVariable("y")).getTest());
View Full Code Here

TOP
Copyright © 2018 www.massapi.com. All rights reserved.
All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.