Examples of halt()

Examples of org.drools.StatefulSession.halt()

509
510
511
512
513
514
515
516
517
518
519
        }).start();
   
        session.startProcess("com.sample.ruleflow", null);

        assertEquals(1, session.getProcessInstances().size());
        session.halt();
       
        final StatefulSession session2 = getSerialisedStatefulSession( session );
       
    new Thread(new Runnable() {
      public void run() {
View Full Code Here

Examples of org.drools.StatefulSession.halt()

523
524
525
526
527
528
529
530
531
532
533
   
        Thread.sleep(400);

        assertEquals(0, session2.getProcessInstances().size());
       
        session2.halt();
    }
   
    public void test6() throws Exception {
        String process =
            "<?xml version=\"1.0\" encoding=\"UTF-8\"?>\n" +
View Full Code Here

Examples of org.drools.StatefulSession.halt()

573
574
575
576
577
578
579
580
581
582
583
    

        ByteArrayOutputStream baos = new ByteArrayOutputStream();
        marshaller.marshall( baos, ksession );
        byte[] b1 = baos.toByteArray();
        session.halt();
        session.dispose();
        Thread.sleep(400);
       
        ByteArrayInputStream bais = new ByteArrayInputStream( b1 );       
        final StatefulSession session2 = ( StatefulSession ) (( StatefulKnowledgeSessionImpl) marshaller.unmarshall( bais ) ).session;
View Full Code Here

Examples of org.drools.StatefulSession.halt()

589
590
591
592
593
594
595
596
597
598
599
        }).start();
   
        Thread.sleep(100);

        assertEquals(0, session2.getProcessInstances().size());
        session2.halt();
    }
   
    private static class TestWorkItemHandler implements WorkItemHandler {
      private WorkItem workItem;
      public void executeWorkItem(WorkItem workItem, WorkItemManager manager) {
View Full Code Here

Examples of org.drools.StatefulSession.halt()

90
91
92
93
94
95
96
97
98
99
100
        ProcessInstance processInstance = ( ProcessInstance )
          session.startProcess("org.drools.timer");
        assertEquals(0, myList.size());
        assertEquals(ProcessInstance.STATE_ACTIVE, processInstance.getState());
        assertEquals(1, ((InternalProcessRuntime) ((InternalWorkingMemory) session).getProcessRuntime()).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

Examples of org.drools.StatefulSession.halt()

120
121
122
123
124
125
126
127
128
129
130
          // do nothing
        }
        assertEquals(5, myList.size());
        assertEquals(ProcessInstance.STATE_COMPLETED, processInstance.getState());
       
        session2.halt();
  }
 
  @SuppressWarnings("unchecked")
  public void testVariableSimpleProcess() throws Exception {
    PackageBuilder builder = new PackageBuilder();
View Full Code Here

Examples of org.drools.StatefulSession.halt()

202
203
204
205
206
207
208
209
210
211
212
        ProcessInstance processInstance = ( ProcessInstance )
          session.startProcess("org.drools.timer", params);
        assertEquals(0, myList.size());
        assertEquals(ProcessInstance.STATE_ACTIVE, processInstance.getState());
        assertEquals(1, ((InternalProcessRuntime) ((InternalWorkingMemory) session).getProcessRuntime()).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

Examples of org.drools.StatefulSession.halt()

232
233
234
235
236
237
238
239
240
241
242
          // 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

Examples of org.drools.StatefulSession.halt()

322
323
324
325
326
327
328
329
330
331
332
          session.startProcess("org.drools.timer");
        assertEquals(0, myList.size());
        assertEquals(ProcessInstance.STATE_ACTIVE, processInstance.getState());
        assertEquals(1, ((InternalProcessRuntime) ((InternalWorkingMemory) session).getProcessRuntime()).getTimerManager().getTimers().size());
       
        session.halt();
       
        final StatefulSession session2 = getSerialisedStatefulSession( session );
        myList = (List<String>) session2.getGlobal( "myList" );
       
    new Thread(new Runnable() {
View Full Code Here

Examples of org.drools.StatefulSession.halt()

344
345
346
347
348
349
350
351
352
353
354
        } catch (InterruptedException e) {
            // do nothing
        }
        assertEquals(1, myList.size());
       
        session2.halt();
  }

  @SuppressWarnings("unchecked")
  public void testOnEntryTimerVariableExecuted() throws Exception {
    PackageBuilder builder = new PackageBuilder();
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.