Hi, I've configured my knowledge base to use the EQUALITY assertion behaviour. When I insert two equal facts into the session, only one gets processed (objects and their fact handles are equal). However when I insert two equal facts via streams, my rule fires twice (objects are equal, but their fact handles are not). Isn't equality assertion behaviour supported when using streams? Here's my rule and test class: package com.sample import com.sample.Message; declare Message @role( event ) @timestamp( time ) end rule "r" when Message( $i:i) //from entry-point "myStream" then System.out.println( $i ); end +++++++++++++++++++++++++++++++++++++++++ public class Message { private int i; private Date time; //getters, setters, hashcode, equals, constructor } +++++++++++++++++++++++++++++++++++++++++ public class DroolsTest { public static final void main(String[] args) { try { KnowledgeBase kbase = readKnowledgeBase(); StatefulKnowledgeSession ksession = kbase.newStatefulKnowledgeSession(); //WorkingMemoryEntryPoint stream = ksession.getWorkingMemoryEntryPoint("myStream"); Date d = new Date(); Message message1 = new Message(1,d); FactHandle fh1 = ksession.insert(message1); //FactHandle fh1 = stream.insert(message1); Message message2 = new Message(1,d); FactHandle fh2 = ksession.insert(message2); //FactHandle fh2 = stream.insert(message2); if (message1.equals(message2) && fh1.equals(fh2)){ System.out.println("equal"); } ksession.fireAllRules(); } catch (Throwable t) { t.printStackTrace(); } } private static KnowledgeBase readKnowledgeBase() throws Exception { KnowledgeBuilder kbuilder = KnowledgeBuilderFactory.newKnowledgeBuilder(); kbuilder.add(ResourceFactory.newClassPathResource("Sample.drl"), ResourceType.DRL); if (kbuilder.getErrors().size() > 0) { throw new IllegalArgumentException("Could not parse knowledge."); } KnowledgeBaseConfiguration kbaseConfig = KnowledgeBaseFactory.newKnowledgeBaseConfiguration(); kbaseConfig.setOption(AssertBehaviorOption.EQUALITY); kbaseConfig.setOption(EventProcessingOption.STREAM); kbaseConfig.setOption(RemoveIdentitiesOption.YES); KnowledgeBase kbase = KnowledgeBaseFactory.newKnowledgeBase(kbaseConfig); kbase.addKnowledgePackages(kbuilder.getKnowledgePackages()); return kbase; } } +++++++++++++++++++++++++++++++++++++++++ Thanks, Jarek _______________________________________________ rules-users mailing list rules-users(a)lists.jboss.org https://lists.jboss.org/mailman/listinfo/rules-users

https://jira.jboss.org/jira/browse/JBRULES-2154 Thanks. Edson Tirelli wrote: > > Jarowslaw, > > Could you please open a JIRA for this. I need to investigate. > Thanks, > > Edson > > 2009/7/1 Jaroslaw Kijanowski <kijanowski(a)gmail.com <mailto: > kijanowski(a)gmail.com&gt;&gt; > > > Hi, > I've configured my knowledge base to use the EQUALITY assertion > behaviour. > When I insert two equal facts into the session, only one gets > processed (objects and their fact handles are equal). > However when I insert two equal facts via streams, my rule fires > twice (objects are equal, but their fact handles are not). Isn't > equality assertion behaviour supported when using streams? > > Here's my rule and test class: > > package com.sample > import com.sample.Message; > declare Message > @role( event ) > @timestamp( time ) > end > > rule "r" > when > Message( $i:i) //from entry-point "myStream" > then > System.out.println( $i ); > end > > +++++++++++++++++++++++++++++++++++++++++ > > public class Message { > > private int i; > private Date time; > //getters, setters, hashcode, equals, constructor > } > > +++++++++++++++++++++++++++++++++++++++++ > > public class DroolsTest { > public static final void main(String[] args) { > try { > KnowledgeBase kbase = readKnowledgeBase(); > StatefulKnowledgeSession ksession = > kbase.newStatefulKnowledgeSession(); > > //WorkingMemoryEntryPoint stream = > ksession.getWorkingMemoryEntryPoint("myStream"); > > Date d = new Date(); > Message message1 = new Message(1,d); > FactHandle fh1 = ksession.insert(message1); > //FactHandle fh1 = stream.insert(message1); > Message message2 = new Message(1,d); > FactHandle fh2 = ksession.insert(message2); > //FactHandle fh2 = stream.insert(message2); > > if (message1.equals(message2) && fh1.equals(fh2)){ > System.out.println("equal"); > } > ksession.fireAllRules(); > } catch (Throwable t) { > t.printStackTrace(); > } > } > > private static KnowledgeBase readKnowledgeBase() throws Exception { > KnowledgeBuilder kbuilder = > KnowledgeBuilderFactory.newKnowledgeBuilder(); > kbuilder.add(ResourceFactory.newClassPathResource("Sample.drl"), > ResourceType.DRL); > if (kbuilder.getErrors().size() > 0) { > throw new IllegalArgumentException("Could not parse knowledge."); > } > KnowledgeBaseConfiguration kbaseConfig = > KnowledgeBaseFactory.newKnowledgeBaseConfiguration(); > kbaseConfig.setOption(AssertBehaviorOption.EQUALITY); > kbaseConfig.setOption(EventProcessingOption.STREAM); > kbaseConfig.setOption(RemoveIdentitiesOption.YES); > > KnowledgeBase kbase = > KnowledgeBaseFactory.newKnowledgeBase(kbaseConfig); > kbase.addKnowledgePackages(kbuilder.getKnowledgePackages()); > return kbase; > } > } > > +++++++++++++++++++++++++++++++++++++++++ > > Thanks, > Jarek > _______________________________________________ > rules-users mailing list > rules-users(a)lists.jboss.org <mailto:rules-users@lists.jboss.org> > https://lists.jboss.org/mailman/listinfo/rules-users > > > > > -- > Edson Tirelli > JBoss Drools Core Development > JBoss by Red Hat @ www.jboss.com <http://www.jboss.com> > > > ------------------------------------------------------------------------ > > _______________________________________________ > rules-users mailing list > rules-users(a)lists.jboss.org > https://lists.jboss.org/mailman/listinfo/rules-users > _______________________________________________ rules-users mailing list rules-users(a)lists.jboss.org https://lists.jboss.org/mailman/listinfo/rules-users