Drools mode stream and containers

Question

HI this is my code.

public static KieContainer createKieContainerForProject() {
        KieServices ks = KieServices.Factory.get();
        // Create a module model
        KieModuleModel kieModuleModel = ks.newKieModuleModel();

        // Base Model from the module model
        KieBaseModel kieBaseModel = kieModuleModel.newKieBaseModel( "KBase" )
                .setDefault( true )
                .setEqualsBehavior( EqualityBehaviorOption.EQUALITY)
                .setEventProcessingMode( EventProcessingOption.STREAM );                

        // Create session model for the Base Model
        KieSessionModel ksessionModel = kieBaseModel.newKieSessionModel( "KSession" )
                .setDefault( true )
                .setType( KieSessionModel.KieSessionType.STATEFUL )
                .setClockType( ClockTypeOption.get("realtime") );

        // Create File System services
        KieFileSystem kFileSystem = ks.newKieFileSystem();

        File file = new File("src/main/resources/rules/Sample.drl");
        Resource resource = ks.getResources().newFileSystemResource(file).setResourceType(ResourceType.DRL);
    kFileSystem.write( resource );       

        KieBuilder kbuilder = ks.newKieBuilder( kFileSystem );
        // kieModule is automatically deployed to KieRepository if successfully built.
        kbuilder.buildAll();

        if (kbuilder.getResults().hasMessages(org.kie.api.builder.Message.Level.ERROR)) {
            throw new RuntimeException("Build time Errors: " + kbuilder.getResults().toString());
        }    
        KieContainer kContainer = ks.newKieContainer(ks.getRepository().getDefaultReleaseId());
        return kContainer;
    }

}

it's dont work when I call the fucntion, and my rules no work too.

my rule is

    rule "Sound the alarm in case temperature rises above threshold"
        when
          TemperatureThreshold( $max : max )
          Number( doubleValue > $max ) from accumulate(
              SensorReading( $temp : temperature ) over window:time( 10m ),
              average( $temp ) )
    then
        // sound the alarm
    end

when I run the program, He says it has error, mode not stream and the code dont work.

how do I put a program in stream mode?

Answer 1

REduce your code, and add -KieBase and KieSession creation:

    KieServices ks = KieServices.Factory.get();
    KieFileSystem kFileSystem = ks.newKieFileSystem();
    FileInputStream fis = new FileInputStream( "...drl" );

    kFileSystem.write("src/main/resources/somename.drl",
              ks.getResources().newInputStreamResource( fis ) ); //XXX

    KieBuilder kbuilder = ks.newKieBuilder( kFileSystem );
    kbuilder.buildAll();
    if (kbuilder.getResults().hasMessages(org.kie.api.builder.Message.Level.ERROR)) {
        throw new RuntimeException("Build time Errors: " + kbuilder.getResults().toString());
    }    
    KieContainer kContainer = ks.newKieContainer(ks.getRepository().getDefaultReleaseId());

    KieBaseConfiguration config = ks.newKieBaseConfiguration();
    config.setOption(EventProcessingOption.STREAM);

    KieBase kieBase = kContainer.newKieBase( config );
    KieSession kieSession = kieBase.newKieSession();

This should give you a session that's capable of running your rule. (

Answer 2

According to the docs, it's as follows:

KieBaseConfiguration config = KieServices.Factory.get().newKieBaseConfiguration();
config.setOption( EventProcessingOption.STREAM );

But it's probably worth taking a look at this Drools test for a working example.