10:37 a.m.
Hi guys,
I was experimenting with Drools fusion (last version) and I have a small
question :
What is the difference between the following (down the page) two rules :
(note the "and" between the patterns) , i.e : how one can understand the
"and" , is it a logical or temporal conjunction ? and finally what is
the implied "relation" between pattern as in rule "b" ? I think it is
an
"and" , but using drools fusion to detect 2 stocks having a temporal
relation (using the after op.) , I found different results when
explicitly using "and" between the patterns and not using it.
One final question , what is the default event policy in fusion ? I can
not find any docu about that.
Thank you for your time -k
rule "a"
when
--pattern1
and
--pattern2
then
--action
end
rule "b"
when
--pattern1
--pattern2
then
--action
end
10:46 a.m.
both rules are exactly the same.
If you found difference could be because your events are arriving in
different orders.. or because the action of one rule cancel the activation
of the second rule (if you are running both rules at the same time)
On Sat, Jan 9, 2010 at 2:37 PM, Khalil Hafsi <hafsi(a)fzi.de> wrote:
Hi guys,
I was experimenting with Drools fusion (last version) and I have a small
question :
What is the difference between the following (down the page) two rules :
(note the "and" between the patterns) , i.e : how one can understand the
"and" , is it a logical or temporal conjunction ? and finally what is
the implied "relation" between pattern as in rule "b" ? I think it is
an
"and" , but using drools fusion to detect 2 stocks having a temporal
relation (using the after op.) , I found different results when
explicitly using "and" between the patterns and not using it.
One final question , what is the default event policy in fusion ? I can
not find any docu about that.
Thank you for your time -k
rule "a"
when
--pattern1
and
--pattern2
then
--action
end
rule "b"
when
--pattern1
--pattern2
then
--action
end
_______________________________________________
rules-users mailing list
rules-users(a)lists.jboss.org
https://lists.jboss.org/mailman/listinfo/rules-users
--
- http://salaboy.wordpress.com
- http://www.jbug.com.ar
- Salatino "Salaboy" Mauricio -
2:29 p.m.
New subject: stream mode
Hi Guys,
I am using DROOLS FUSION last version
It is very important for me that events arrive in the order i fire them
, this is a part of the code used for stream mode :
KnowledgeBuilder kbuilder =
KnowledgeBuilderFactory.newKnowledgeBuilder();
kbuilder.add(ResourceFactory.newClassPathResource("pol.drl"),
ResourceType.DRL);
if ( kbuilder.hasErrors() ) {
System.err.println( kbuilder.getErrors().toString() );
}
KnowledgeBaseConfiguration config =
KnowledgeBaseFactory.newKnowledgeBaseConfiguration();
config.setOption(EventProcessingOption.STREAM);
KnowledgeBase kbase =
KnowledgeBaseFactory.newKnowledgeBase(config);
kbase.addKnowledgePackages(kbuilder.getKnowledgePackages());
StatefulKnowledgeSession ksession =
kbase.newStatefulKnowledgeSession();
after this part I just start inserting Events into the ksession , i.e
ksession.insert(new Event(a)) ...
does this suffice to make the the engine in stream mode and hence ordered ?
In the example app , Events were fired as they arrive , but a timestamp
was given , and also agenda and jobs were used.
Is that necessary for the engine to work in stream mode ?
I have a piece of code that gives me different results every time I run
it ?! it is in stream mode , but for some reason the rule either do not
fire , or do not print the output. is there a way to debug into this ?
thank you .
k-
3:22 p.m.
New subject: stream mode
you need to call ksession.fireAllRules() after: ksession.insert(new
Event(a))
On Sun, Jan 10, 2010 at 6:29 PM, Khalil Hafsi <hafsi(a)fzi.de> wrote:
Hi Guys,
I am using DROOLS FUSION last version
It is very important for me that events arrive in the order i fire them
, this is a part of the code used for stream mode :
> KnowledgeBuilder kbuilder =
> KnowledgeBuilderFactory.newKnowledgeBuilder();
>
> kbuilder.add(ResourceFactory.newClassPathResource("pol.drl"),
> ResourceType.DRL);
> if ( kbuilder.hasErrors() ) {
> System.err.println( kbuilder.getErrors().toString() );
> }
> KnowledgeBaseConfiguration config =
> KnowledgeBaseFactory.newKnowledgeBaseConfiguration();
> config.setOption(EventProcessingOption.STREAM);
> KnowledgeBase kbase =
> KnowledgeBaseFactory.newKnowledgeBase(config);
> kbase.addKnowledgePackages(kbuilder.getKnowledgePackages());
>
> StatefulKnowledgeSession ksession =
> kbase.newStatefulKnowledgeSession();
after this part I just start inserting Events into the ksession , i.e
ksession.insert(new Event(a)) ...
does this suffice to make the the engine in stream mode and hence ordered ?
In the example app , Events were fired as they arrive , but a timestamp
was given , and also agenda and jobs were used.
Is that necessary for the engine to work in stream mode ?
I have a piece of code that gives me different results every time I run
it ?! it is in stream mode , but for some reason the rule either do not
fire , or do not print the output. is there a way to debug into this ?
thank you .
k-
_______________________________________________
rules-users mailing list
rules-users(a)lists.jboss.org
https://lists.jboss.org/mailman/listinfo/rules-users
--
- http://salaboy.wordpress.com
- http://www.jbug.com.ar
- Salatino "Salaboy" Mauricio -
3:44 p.m.
New subject: stream mode
if you don't put any timestamp fusion will automatically assign the
timestamp at the insertion time.
I see the problem now. You are probably not using the entry points for
events.
In your rules you need to add for example:
Alarm() from entry-point "alarmsEntryPoint"
and then you need to insert the events in:
ksession.getWorkingMemoryEntryPoint("alarmsEntryPoint").insert(new Alarm());
that will treat your POJO as event in fusion.
Please read the fusion documentation:
http://hudson.jboss.org/hudson/job/drools/lastSuccessfulBuild/artifact/tr...
2010/1/10 Khalil Hafsi <hafsi(a)fzi.de>
Hi Mauricio,
Of course I did. What about the timestamps , agenda and jobs that were used
in the example , are they necessary ?
Thanks,
k-
Mauricio Salatino wrote:
you need to call ksession.fireAllRules() after: ksession.insert(new
Event(a))
On Sun, Jan 10, 2010 at 6:29 PM, Khalil Hafsi <hafsi(a)fzi.de> wrote:
> Hi Guys,
>
> I am using DROOLS FUSION last version
> It is very important for me that events arrive in the order i fire them
> , this is a part of the code used for stream mode :
> > KnowledgeBuilder kbuilder =
> > KnowledgeBuilderFactory.newKnowledgeBuilder();
> >
> > kbuilder.add(ResourceFactory.newClassPathResource("pol.drl"),
> > ResourceType.DRL);
> > if ( kbuilder.hasErrors() ) {
> > System.err.println( kbuilder.getErrors().toString() );
> > }
> > KnowledgeBaseConfiguration config =
> > KnowledgeBaseFactory.newKnowledgeBaseConfiguration();
> > config.setOption(EventProcessingOption.STREAM);
> > KnowledgeBase kbase =
> > KnowledgeBaseFactory.newKnowledgeBase(config);
> > kbase.addKnowledgePackages(kbuilder.getKnowledgePackages());
> >
> > StatefulKnowledgeSession ksession =
> > kbase.newStatefulKnowledgeSession();
>
> after this part I just start inserting Events into the ksession , i.e
> ksession.insert(new Event(a)) ...
>
> does this suffice to make the the engine in stream mode and hence ordered
> ?
> In the example app , Events were fired as they arrive , but a timestamp
> was given , and also agenda and jobs were used.
> Is that necessary for the engine to work in stream mode ?
> I have a piece of code that gives me different results every time I run
> it ?! it is in stream mode , but for some reason the rule either do not
> fire , or do not print the output. is there a way to debug into this ?
>
> thank you .
> k-
>
> _______________________________________________
> rules-users mailing list
> rules-users(a)lists.jboss.org
> https://lists.jboss.org/mailman/listinfo/rules-users
>
--
- http://salaboy.wordpress.com
- http://www.jbug.com.ar
- Salatino "Salaboy" Mauricio -
_______________________________________________
rules-users mailing list
rules-users(a)lists.jboss.org
https://lists.jboss.org/mailman/listinfo/rules-users
--
- http://salaboy.wordpress.com
- http://www.jbug.com.ar
- Salatino "Salaboy" Mauricio -
6:10 p.m.
New subject: stream mode
Not really. The session.insert(...) method will insert the facts/events
into the "default" entry point. You don't need to use a named entry point
if
you don't want to. What makes the engine treat a POJO as an event is the
@role(event) metadata in the declare statement.
Regarding the original question, the engine does not explicitly re-order
any events/facts. They are processed in the order they are inserted, unless
you are using partitions (it seems you are not). If order is important for
you, just make sure you insert them in the proper order and make sure the
timestamping strategy you are using is adequate.
Edson
2010/1/10 Mauricio Salatino <salaboy(a)gmail.com>
if you don't put any timestamp fusion will automatically assign
the
timestamp at the insertion time.
I see the problem now. You are probably not using the entry points for
events.
In your rules you need to add for example:
Alarm() from entry-point "alarmsEntryPoint"
and then you need to insert the events in:
ksession.getWorkingMemoryEntryPoint("alarmsEntryPoint").insert(new
Alarm());
that will treat your POJO as event in fusion.
Please read the fusion documentation:
http://hudson.jboss.org/hudson/job/drools/lastSuccessfulBuild/artifact/tr...
2010/1/10 Khalil Hafsi <hafsi(a)fzi.de>
Hi Mauricio,
>
> Of course I did. What about the timestamps , agenda and jobs that were
> used in the example , are they necessary ?
>
> Thanks,
> k-
>
> Mauricio Salatino wrote:
>
> you need to call ksession.fireAllRules() after: ksession.insert(new
> Event(a))
>
>
> On Sun, Jan 10, 2010 at 6:29 PM, Khalil Hafsi <hafsi(a)fzi.de> wrote:
>
>> Hi Guys,
>>
>> I am using DROOLS FUSION last version
>> It is very important for me that events arrive in the order i fire them
>> , this is a part of the code used for stream mode :
>> > KnowledgeBuilder kbuilder =
>> > KnowledgeBuilderFactory.newKnowledgeBuilder();
>> >
>> > kbuilder.add(ResourceFactory.newClassPathResource("pol.drl"),
>> > ResourceType.DRL);
>> > if ( kbuilder.hasErrors() ) {
>> > System.err.println( kbuilder.getErrors().toString() );
>> > }
>> > KnowledgeBaseConfiguration config =
>> > KnowledgeBaseFactory.newKnowledgeBaseConfiguration();
>> > config.setOption(EventProcessingOption.STREAM);
>> > KnowledgeBase kbase =
>> > KnowledgeBaseFactory.newKnowledgeBase(config);
>> >
>> kbase.addKnowledgePackages(kbuilder.getKnowledgePackages());
>> >
>> > StatefulKnowledgeSession ksession =
>> > kbase.newStatefulKnowledgeSession();
>>
>> after this part I just start inserting Events into the ksession , i.e
>> ksession.insert(new Event(a)) ...
>>
>> does this suffice to make the the engine in stream mode and hence ordered
>> ?
>> In the example app , Events were fired as they arrive , but a timestamp
>> was given , and also agenda and jobs were used.
>> Is that necessary for the engine to work in stream mode ?
>> I have a piece of code that gives me different results every time I run
>> it ?! it is in stream mode , but for some reason the rule either do not
>> fire , or do not print the output. is there a way to debug into this ?
>>
>> thank you .
>> k-
>>
>> _______________________________________________
>> rules-users mailing list
>> rules-users(a)lists.jboss.org
>> https://lists.jboss.org/mailman/listinfo/rules-users
>>
>
>
>
> --
> - http://salaboy.wordpress.com
> - http://www.jbug.com.ar
> - Salatino "Salaboy" Mauricio -
>
>
> _______________________________________________
> rules-users mailing list
> rules-users(a)lists.jboss.org
> https://lists.jboss.org/mailman/listinfo/rules-users
>
>
--
- http://salaboy.wordpress.com
- http://www.jbug.com.ar
- Salatino "Salaboy" Mauricio -
_______________________________________________
rules-users mailing list
rules-users(a)lists.jboss.org
https://lists.jboss.org/mailman/listinfo/rules-users
--
Edson Tirelli
JBoss Drools Core Development
JBoss by Red Hat @ www.jboss.com
6:14 p.m.
New subject: stream mode
It's good to know I always use entry points
2010/1/10 Edson Tirelli <ed.tirelli(a)gmail.com>
Not really. The session.insert(...) method will insert the facts/events
into the "default" entry point. You don't need to use a named entry point
if
you don't want to. What makes the engine treat a POJO as an event is the
@role(event) metadata in the declare statement.
Regarding the original question, the engine does not explicitly re-order
any events/facts. They are processed in the order they are inserted, unless
you are using partitions (it seems you are not). If order is important for
you, just make sure you insert them in the proper order and make sure the
timestamping strategy you are using is adequate.
Edson
2010/1/10 Mauricio Salatino <salaboy(a)gmail.com>
if you don't put any timestamp fusion will automatically assign the
> timestamp at the insertion time.
> I see the problem now. You are probably not using the entry points for
> events.
> In your rules you need to add for example:
> Alarm() from entry-point "alarmsEntryPoint"
>
> and then you need to insert the events in:
>
> ksession.getWorkingMemoryEntryPoint("alarmsEntryPoint").insert(new
> Alarm());
>
> that will treat your POJO as event in fusion.
> Please read the fusion documentation:
>
>
http://hudson.jboss.org/hudson/job/drools/lastSuccessfulBuild/artifact/tr...
>
>
> 2010/1/10 Khalil Hafsi <hafsi(a)fzi.de>
>
> Hi Mauricio,
>>
>> Of course I did. What about the timestamps , agenda and jobs that were
>> used in the example , are they necessary ?
>>
>> Thanks,
>> k-
>>
>> Mauricio Salatino wrote:
>>
>> you need to call ksession.fireAllRules() after: ksession.insert(new
>> Event(a))
>>
>>
>> On Sun, Jan 10, 2010 at 6:29 PM, Khalil Hafsi <hafsi(a)fzi.de> wrote:
>>
>>> Hi Guys,
>>>
>>> I am using DROOLS FUSION last version
>>> It is very important for me that events arrive in the order i fire them
>>> , this is a part of the code used for stream mode :
>>> > KnowledgeBuilder kbuilder =
>>> > KnowledgeBuilderFactory.newKnowledgeBuilder();
>>> >
>>> > kbuilder.add(ResourceFactory.newClassPathResource("pol.drl"),
>>> > ResourceType.DRL);
>>> > if ( kbuilder.hasErrors() ) {
>>> > System.err.println( kbuilder.getErrors().toString() );
>>> > }
>>> > KnowledgeBaseConfiguration config =
>>> > KnowledgeBaseFactory.newKnowledgeBaseConfiguration();
>>> > config.setOption(EventProcessingOption.STREAM);
>>> > KnowledgeBase kbase =
>>> > KnowledgeBaseFactory.newKnowledgeBase(config);
>>> >
>>> kbase.addKnowledgePackages(kbuilder.getKnowledgePackages());
>>> >
>>> > StatefulKnowledgeSession ksession =
>>> > kbase.newStatefulKnowledgeSession();
>>>
>>> after this part I just start inserting Events into the ksession , i.e
>>> ksession.insert(new Event(a)) ...
>>>
>>> does this suffice to make the the engine in stream mode and hence
>>> ordered ?
>>> In the example app , Events were fired as they arrive , but a timestamp
>>> was given , and also agenda and jobs were used.
>>> Is that necessary for the engine to work in stream mode ?
>>> I have a piece of code that gives me different results every time I run
>>> it ?! it is in stream mode , but for some reason the rule either do not
>>> fire , or do not print the output. is there a way to debug into this ?
>>>
>>> thank you .
>>> k-
>>>
>>> _______________________________________________
>>> rules-users mailing list
>>> rules-users(a)lists.jboss.org
>>> https://lists.jboss.org/mailman/listinfo/rules-users
>>>
>>
>>
>>
>> --
>> - http://salaboy.wordpress.com
>> - http://www.jbug.com.ar
>> - Salatino "Salaboy" Mauricio -
>>
>>
>> _______________________________________________
>> rules-users mailing list
>> rules-users(a)lists.jboss.org
>> https://lists.jboss.org/mailman/listinfo/rules-users
>>
>>
>
>
> --
> - http://salaboy.wordpress.com
> - http://www.jbug.com.ar
> - Salatino "Salaboy" Mauricio -
>
> _______________________________________________
> rules-users mailing list
> rules-users(a)lists.jboss.org
> https://lists.jboss.org/mailman/listinfo/rules-users
>
>
--
Edson Tirelli
JBoss Drools Core Development
JBoss by Red Hat @ www.jboss.com
_______________________________________________
rules-users mailing list
rules-users(a)lists.jboss.org
https://lists.jboss.org/mailman/listinfo/rules-users
--
- http://salaboy.wordpress.com
- http://www.jbug.com.ar
- Salatino "Salaboy" Mauricio -
5463
days inactive
5465
days old
8 comments
3 participants
participants (3)
-
Edson Tirelli -
Khalil Hafsi -
Mauricio Salatino