Package org.drools

Examples of org.drools.StatefulSession.halt()

1004
1005
1006
1007
1008
1009
1010
1011
1012
1013
1014
        workingMemory.fireAllRules();

        assertEquals( 1,
                      list.size() );

        workingMemory.halt();
    }

    private RuleBase loadRuleBase( final Reader reader ) throws IOException,
                                                        DroolsParserException,
                                                        Exception {
View Full Code Here
894
895
896
897
898
899
900
901
902
903
904
        workingMemory.getAgenda().activateRuleFlowGroup( "Group1" );
        workingMemory.fireAllRules();

        assertEquals( 1, list.size() );

        workingMemory.halt();
    }

    private RuleBase loadRuleBase( final Reader reader ) throws IOException, DroolsParserException, Exception {
        final DrlParser parser = new DrlParser();
        final PackageDescr packageDescr = parser.parse( reader );
View Full Code Here
1004
1005
1006
1007
1008
1009
1010
1011
1012
1013
1014
        Thread.sleep(1000);
       
        assertEquals( 1,
                      list.size() );
       
        workingMemory.halt();
    }

    public void testRuleFlow() throws Exception {
        final PackageBuilder builder = new PackageBuilder();
        builder.addPackageFromDrl( new InputStreamReader( getClass().getResourceAsStream( "ruleflow.drl" ) ) );
View Full Code Here
1013
1014
1015
1016
1017
1018
1019
1020
1021
1022
1023
        workingMemory.getAgenda().activateRuleFlowGroup( "Group1" );
        workingMemory.fireAllRules();

        assertEquals( 1, list.size() );

        workingMemory.halt();
    }

    private RuleBase loadRuleBase( final Reader reader ) throws IOException, DroolsParserException, Exception {
        final DrlParser parser = new DrlParser();
        final PackageDescr packageDescr = parser.parse( reader );
View Full Code Here
1004
1005
1006
1007
1008
1009
1010
1011
1012
1013
1014
        workingMemory.fireAllRules();

        assertEquals( 1,
                      list.size() );

        workingMemory.halt();
    }

    private RuleBase loadRuleBase( final Reader reader ) throws IOException,
                                                        DroolsParserException,
                                                        Exception {
View Full Code Here
87
88
89
90
91
92
93
94
95
96
97
        ProcessInstance processInstance = ( ProcessInstance )
          session.startProcess("org.drools.timer");
        assertEquals(0, myList.size());
        assertEquals(ProcessInstance.STATE_ACTIVE, processInstance.getState());
        assertEquals(1, session.getTimerManager().getTimers().size());
        session.halt();
       
        final StatefulSession session2 = getSerialisedStatefulSession( session );
        myList = (List<Message>) session2.getGlobal( "myList" );
    new Thread(new Runnable() {
      public void run() {
View Full Code Here
117
118
119
120
121
122
123
124
125
126
127
          // do nothing
        }
        assertEquals(5, myList.size());
        assertEquals(ProcessInstance.STATE_COMPLETED, processInstance.getState());
       
        session2.halt();
  }
 
  public void testIncorrectTimerNode() throws Exception {
    PackageBuilder builder = new PackageBuilder();
    Reader source = new StringReader(
View Full Code Here
207
208
209
210
211
212
213
214
215
216
217
          session.startProcess("org.drools.timer");
        assertEquals(0, myList.size());
        assertEquals(ProcessInstance.STATE_ACTIVE, processInstance.getState());
        assertEquals(1, session.getTimerManager().getTimers().size());
       
        session.halt();
       
        final StatefulSession session2 = getSerialisedStatefulSession( session );
        myList = (List<String>) session2.getGlobal( "myList" );
       
    new Thread(new Runnable() {
View Full Code Here
229
230
231
232
233
234
235
236
237
238
239
        } catch (InterruptedException e) {
            // do nothing
        }
        assertEquals(1, myList.size());
       
        session2.halt();
  }

  @SuppressWarnings("unchecked")
  public void testOnEntryTimerWorkItemExecuted() throws Exception {
    PackageBuilder builder = new PackageBuilder();
View Full Code Here
290
291
292
293
294
295
296
297
298
299
300
          session.startProcess("org.drools.timer");
        assertEquals(0, myList.size());
        assertEquals(ProcessInstance.STATE_ACTIVE, processInstance.getState());
        assertEquals(1, session.getTimerManager().getTimers().size());
       
        session.halt();
       
        final StatefulSession session2 = getSerialisedStatefulSession( session );
        myList = (List<String>) session2.getGlobal( "myList" );
       
    new Thread(new Runnable() {
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.