[rules-users] CEP Stream Mode

Hello all, I'd like to get Drools working in such a way that it is always running and I can just stream new events into the runtime and have it execute rules against them. From what I can tell I need to use stream mode in order to do this. I've got everything set up for how I think it should work (based on what I can decipher from the documentation) but what's happening is that I'm never getting a hit on the rules I write. I can see the event be asserted but nothing happens. Here is my set up... KnowledgeBaseConfiguration config = KnowledgeBaseFactory.newKnowledgeBaseConfiguration(); config.setOption(EventProcessingOption.STREAM); setKnowledgeBase(KnowledgeBaseFactory.newKnowledgeBase(config)); // Create a knowledge agent to pull load the necessary resources kagent = KnowledgeAgentFactory.newKnowledgeAgent("MyAgenda", getKnowledgeBase()); initResources(kagent); setKnowledgeBase(kagent.getKnowledgeBase()); getSession().addEventListener(new DebugAgendaEventListener()); getSession().addEventListener(new DebugWorkingMemoryEventListener()); And here is how I start up Drools... thread = new Thread() { @Override public void run() { getSession().fireUntilHalt(); } }; thread.run(); I then feed events into the engine like this... WorkingMemoryEntryPoint stream = getSession().getWorkingMemoryEntryPoint(origin); stream.insert(event); I'm obviously missing something in my setup. Any help on understanding how this is supposed to work is greatly appreciated. Again, the goal here is to get Drools in a state that is always running so I can pipe in events to it and have rules execute against them. Jean-Philippe