2009/7/1 Jaroslaw Kijanowski <kijanowski@gmail.com>

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@lists.jboss.org
https://lists.jboss.org/mailman/listinfo/rules-users