Package org.drools.agent.impl

Examples of org.drools.agent.impl.PrintStreamSystemEventListener


    public static final String TMP_DIR = "target/classes/";
   
    @Test
    public void testPKGByResourceChangeScanner() throws Exception {
       
        SystemEventListenerFactory.setSystemEventListener(new PrintStreamSystemEventListener(System.out));       

        // create a PKG file
        PackageBuilder builder = new PackageBuilder();
        builder.addPackageFromDrl( new InputStreamReader( getClass().getResourceAsStream( "Sample.drl" ) ) );
        Package pkg = builder.getPackage();
View Full Code Here


   *
   */
  @Test
    public void testXLSByResourceChangeScanner() throws Exception {
       
        SystemEventListenerFactory.setSystemEventListener(new PrintStreamSystemEventListener(System.out));       
       
        // first file
        File ruleFile = new File(TMP_DIR + "sample.xls");
        copy(getClass().getResourceAsStream("sample.xls"), new FileOutputStream(ruleFile));       
       
View Full Code Here

                return new PasswordAuthentication("admin", "admin".toCharArray());
            }
        });

        // system event listener
        SystemEventListenerFactory.setSystemEventListener(new PrintStreamSystemEventListener(System.out));

        KnowledgeBase kbase = KnowledgeBaseFactory.newKnowledgeBase();
        KnowledgeAgentConfiguration conf = KnowledgeAgentFactory.newKnowledgeAgentConfiguration();
        // needs to be newInstance=true, bugzilla 733008 works fine with newInstance=false
        conf.setProperty("drools.agent.newInstance", "true");
View Full Code Here



        KnowledgeBase kbase = KnowledgeBaseFactory.newKnowledgeBase();
        KnowledgeAgent kagent = createKAgent( kbase, false, true );
        kagent.setSystemEventListener( new PrintStreamSystemEventListener() );

        ByteArrayResource bres = (ByteArrayResource) ResourceFactory.newByteArrayResource( s1.getBytes() );
        bres.setResourceType( ResourceType.DRL );

        ChangeSetImpl cs = new ChangeSetImpl();
View Full Code Here

                     "";


        KnowledgeBase kbase = KnowledgeBaseFactory.newKnowledgeBase();
        KnowledgeAgent kagent = createKAgent( kbase, false, true );
        kagent.setSystemEventListener( new PrintStreamSystemEventListener() );

        ByteArrayResource bres = (ByteArrayResource) ResourceFactory.newByteArrayResource( drl.getBytes() );
        bres.setResourceType( ResourceType.DRL );

        ChangeSetImpl cs = new ChangeSetImpl();
View Full Code Here

        //Create a new Agent with newInstance=false
        KnowledgeBase kbase = KnowledgeBaseFactory.newKnowledgeBase();
        KnowledgeAgent kagent = this.createKAgent( kbase, false, false );

        kagent.setSystemEventListener(new PrintStreamSystemEventListener(System.out));

        //Agent: take care of them!
        this.applyChangeSet(kagent, ResourceFactory.newByteArrayResource(xml.getBytes()));

        StatefulKnowledgeSession ksession = createKnowledgeSession(kbase);
View Full Code Here

        //Create a new Agent with newInstance=false
        KnowledgeBase kbase = KnowledgeBaseFactory.newKnowledgeBase();
        KnowledgeAgent kagent = this.createKAgent( kbase, false );

        kagent.setSystemEventListener( new PrintStreamSystemEventListener( System.out ) );

        //Agent: take care of them!
        this.applyChangeSet( kagent, ResourceFactory.newByteArrayResource(xml.getBytes() ) );

        StatefulKnowledgeSession ksession = createKnowledgeSession( kbase );
View Full Code Here

        KnowledgeBase kbase = KnowledgeBaseFactory.newKnowledgeBase();
        KnowledgeAgent kagent = this.createKAgent( kbase, false );

        List<String> list = new ArrayList<String>();

        kagent.setSystemEventListener( new PrintStreamSystemEventListener( System.out ) );

        //Agent: take care of them!
        this.applyChangeSet( kagent, ResourceFactory.newByteArrayResource( xml.getBytes() ) );

        StatefulKnowledgeSession ksession = createKnowledgeSession( kbase );
View Full Code Here

        KnowledgeBase kbase = KnowledgeBaseFactory.newKnowledgeBase();
        KnowledgeAgent kagent = this.createKAgent( kbase, false, true );

        List<String> list = new ArrayList<String>();

        kagent.setSystemEventListener( new PrintStreamSystemEventListener( System.out ) );

        //Agent: take care of them!
        this.applyChangeSet( kagent, ResourceFactory.newByteArrayResource( xml.getBytes() ) );

        StatefulKnowledgeSession ksession = createKnowledgeSession( kbase );
View Full Code Here

     
      public void afterChangeSetApplied(AfterChangeSetAppliedEvent event) {
      }
    });
   
    SystemEventListenerFactory.setSystemEventListener(new PrintStreamSystemEventListener());
    agent.applyChangeSet(ResourceFactory.newReaderResource(new StringReader(changeset)));
    KnowledgeBase kbase = agent.getKnowledgeBase();
   
    assertEquals(2, kbase.getProcesses().size());
    assertEquals(2, kbase.getKnowledgePackage("dummy").getProcesses().size());
View Full Code Here

TOP

Related Classes of org.drools.agent.impl.PrintStreamSystemEventListener

Copyright © 2018 www.massapicom. 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.