Re: [rules-users] Help with StatefulSession and Stream Mode

Hi all, I am stuck trying to understand how to setup my drools system.. I am using Stream mode, with some negative rules, and a continuous stream of facts. Facts are evaluated and will in turn insert events into the memory if required. I thought it would be like this: First, setup, KnowledgeBaseConfiguration conf = KnowledgeBaseFactory.newKnowledgeBaseConfiguration(); conf.setOption(EventProcessingOption.STREAM); KnowledgeBase kbase = KnowledgeBaseFactory.newKnowledgeBase(conf); kbase.addKnowledgePackages(builder.getKnowledgePackages()); ksession = kbase.newStatefulKnowledgeSession(); Then we have ksession... The code that handles an incoming message will have a reference to ksession.. and it will run: WorkingMemoryEntryPoint eStream = ksession.getWorkingMemoryEntryPoint("MessageStream"); eStream.insert(msg); ksession.fireAllRules(); but here is my problem... as some rules have things like not(Event(this after [0s,90m] $a)) then the fireAllRules can wait for the 90minutes to pass before completing.. How do I do it so that there is one WorkingMemory, and I can pump facts into that memory and the engine just keeps running and my 'inputter' doesn't hang..? Thanks Ric