Examples of org.kie.api.runtime.KieSession.dispose()

org.kie.api.runtime.KieSession.dispose()


        Person darth = new Person("Darth", 15);
        ksession.insert(darth);
        ksession.fireAllRules();


        ksession.dispose(); // Stateful rule session must always be disposed when finished
    }


    public static void pause() {
        System.out.println( "Pressure enter to continue" );
        Scanner keyboard = new Scanner(System.in);

View Full Code Here

        // Create a session and fire rules
        KieContainer kc = ks.newKieContainer( km.getReleaseId() );
        KieSession ksession = kc.newKieSession();
        ksession.insert( new Message( "Hello World" ) );
        assertEquals( 2, ksession.fireAllRules() );
        ksession.dispose();
    }


    @Test
    public void testGetKieBaseAfterKieSessionCreation() {
        final String KBASE_NAME = "kieBase";

View Full Code Here

        ksession.delete(fireBlockerRule);
        list.clear();
        ksession.fireAllRules();
        assertEquals(0, list.size());


        ksession.dispose();
        list.clear();
    }


    @Test
    public void testExplicitUndercutWithDeclarativeAgenda() {

View Full Code Here

        ksession.setGlobal( "list", list );


        ksession.fireAllRules();


        assertEquals( 1, list.size() );
        ksession.dispose();


    }




    @Test

View Full Code Here

        ksession.setGlobal( "list", list );


        ksession.fireAllRules();


        assertEquals( 1, list.size() );
        ksession.dispose();


    }


    @Test
    public void testTemporalEvaluatorsUsingSelfDates() throws InterruptedException {

View Full Code Here

        ksession.setGlobal( "list", list );


        ksession.fireAllRules();


        assertEquals( 1, list.size() );
        ksession.dispose();


    }


    @Test
    public void testEventOffsetExpirationOverflow() {

View Full Code Here

        // make sure the event is in the entry-point
        assertFalse(entryPoint.getObjects().contains(event));
        assertTrue(entryPoint.getObjects().contains(event2));
        assertEquals(entryPoint.getObject(handle), event2);


        kieSession.dispose();
    }


    public static class TestEvent implements Serializable {


        private final String name;

View Full Code Here

        clock.advanceTime( 10, TimeUnit.SECONDS );
        entryPoint.insert(new TestEvent("three"));
        QueryResults results = ksession.getQueryResults("EventsBeforeNineSeconds");
        assertEquals(1, results.size());


        ksession.dispose();
    }






    public static class ProbeEvent {

View Full Code Here

        ksession.setGlobal( "list", list );


        ksession.fireAllRules();


        assertEquals( 1, list.size() );
        ksession.dispose();


    }


    @Test
    public void testTemporalEvaluatorsUsingRawDateFields() throws InterruptedException {

View Full Code Here

        System.out.println( "***** " + list + " *****");
        assertEquals( Arrays.asList( 0L, 0L, 0L ), list );
        list.clear();
        ksession.retract( handle );


        ksession.dispose();
    }


    @Test
    public void testCronFire() throws InterruptedException {
        // BZ-1059372

View Full Code Here

0 1 2 3 4 5 6 7 8 9

TOP

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.