Trying to get Sliding Windows to work
by ober0n
Hi, I am having trouble understanding how to use sliding windows. Here are
the relevant snippets of code I added to the Hello World example under
Drools Fusion. I also added a timestamp to the Message class (with
corresponding get and set functions).
DroolsTest.java:
for(int i=0; i < 6; i++) {
Thread.sleep(10000);
currDate = new Date();
Message message = new Message();
message.setMessage("Hello World");
message.setStatus(Message.HELLO);
message.setTemporalStamp(currDate);
ksession.insert(message);
}
ksession.fireAllRules();
Sample.drl:
declare Message
@role( event )
@timestamp( temporalStamp )
end
rule "Hello World"
when
m : Message( status == Message.HELLO, myMessage : message, ts :
temporalStamp ) over window:time( 15s )
then
System.out.println( myMessage + ": In the 1 minute window with timestamp:
" + ts );
End
My intention was to print out all messages with status = HELLO AND within 15
seconds of inserting the message into the session.
I thought what would happen is 2 out of the 6 Messages I sent would be
printed out. But, instead, all 6 messages I sent are printed.
What am I doing wrong?
--
View this message in context: http://www.nabble.com/Trying-to-get-Sliding-Windows-to-work-tp22735051p22...
Sent from the drools - user mailing list archive at Nabble.com.
17 years, 2 months
Drools flow and BPEL (Drools 5.0.0.M5)
by Umesh Wankhede
Hi
I am trying to evaluate various features (rules and workflow) of Drools
5.0. What I understand from docs (drools-docs-flow.pdf - page 5) is that
the Drools flow engine is based on generic process engine that allows
the execution of different process languages like RuleFlow, BPEL,
OSWorkflow, etc. Although I am able to do PoC (Proof of Concept) with
RuleFlow, there isn't any documentation/samples available for using BPEL
as process language. Also I don't find any more information on blogs, etc.
If anyone has done something similar, please let me know, or any
pointers would help.
Thanks
Umesh
Legal Notice: This transmission, including any attachments, is confidential, proprietary, and may be privileged. It is intended solely for
the intended recipient. If you are not the intended recipient, you have received this transmission in error and you are hereby advised that any
review, disclosure, copying, distribution, or use of this transmission, or any of the information included therein, is unauthorized and strictly
prohibited. If you have received this transmission in error, please immediately notify the sender by reply and permanently delete all copies of
this transmission and its attachments
17 years, 2 months
Guvnor, database and rule language
by Anu＠work
I am trying to use drools to evaluate the following rule:
Given a telephone number, if the telephone number already exists in database
and has a balance > 0, set isAllowed = false. I cannot figure out how to
write the rule.
This is my object
public class Customer implements Serializable {
private static final long serialVersionUID = 1L;
private String tn;
private Double balance;
private Boolean isAllowed;
// getters/ setters
}
Can anyone help me with the rule below? The TN is set in the input fact. Is
the query below correct? It looks incorrect.
global org.hibernate.Session hibernateSession;
when
cust1:Customer()
cust2:Customer() from hibernateSession.createQuery("Select * from
Customers Where TN = :tn and balance >
0).setProperties({"tn":cust1.getTn()})list()
then
cust1.setIsAllowed(false);
--
View this message in context: http://www.nabble.com/Guvnor%2C-database-and-rule-language-tp22810206p228...
Sent from the drools - user mailing list archive at Nabble.com.
17 years, 2 months
stack overflow in work items
by Garrett Conaty
My scenario is a rule that is firing over a collection. For each item
in that collection a ruleflow starts to handle it. Right now the
ruleflow just uses the log workitem to log the steps. When there are
~600 items in the collection I'm getting stack overflows. Granted the
processes could be optimized (I'd really like to take each thing in
the collection that matched and start a process for the set of them).
Still is there a limit to the number of active processes with work
items?
java.lang.StackOverflowError
at java.lang.Long.valueOf(Long.java:547)
at
org
.drools
.workflow.core.impl.NodeContainerImpl.getNode(NodeContainerImpl.java:44)
at
org
.drools
.workflow
.core.impl.WorkflowProcessImpl.getNode(WorkflowProcessImpl.java:47)
at
org
.drools
.workflow
.core
.impl.WorkflowProcessImpl.internalGetNode(WorkflowProcessImpl.java:51)
at
org
.drools
.workflow.instance.impl.NodeInstanceImpl.getNode(NodeInstanceImpl.java:
90)
at
org
.drools
.workflow
.instance
.impl
.ExtendedNodeInstanceImpl
.getExtendedNode(ExtendedNodeInstanceImpl.java:24)
at
org
.drools
.workflow
.instance
.impl
.ExtendedNodeInstanceImpl.triggerEvent(ExtendedNodeInstanceImpl.java:41)
at
org
.drools
.workflow
.instance
.impl
.ExtendedNodeInstanceImpl
.internalTrigger(ExtendedNodeInstanceImpl.java:28)
at
org
.drools
.workflow
.instance
.node
.EventBasedNodeInstance.internalTrigger(EventBasedNodeInstance.java:30)
at
org
.drools
.workflow
.instance
.node.WorkItemNodeInstance.internalTrigger(WorkItemNodeInstance.java:80)
at
org
.drools
.workflow.instance.impl.NodeInstanceImpl.trigger(NodeInstanceImpl.java:
111)
at
org
.drools
.workflow
.instance
.impl.NodeInstanceImpl.triggerConnection(NodeInstanceImpl.java:141)
at
org
.drools
.workflow
.instance.impl.NodeInstanceImpl.triggerCompleted(NodeInstanceImpl.java:
128)
at
org
.drools
.workflow
.instance
.impl
.ExtendedNodeInstanceImpl
.triggerCompleted(ExtendedNodeInstanceImpl.java:37)
at
org
.drools
.workflow
.instance
.node
.EventBasedNodeInstance.triggerCompleted(EventBasedNodeInstance.java:96)
at
org
.drools
.workflow
.instance
.node
.EventBasedNodeInstance.triggerCompleted(EventBasedNodeInstance.java:77)
at
org
.drools
.workflow
.instance
.node.WorkItemNodeInstance.triggerCompleted(WorkItemNodeInstance.java:
192)
at
org
.drools
.workflow
.instance
.node.WorkItemNodeInstance.workItemCompleted(WorkItemNodeInstance.java:
244)
at
org
.drools
.workflow
.instance
.node.WorkItemNodeInstance.signalEvent(WorkItemNodeInstance.java:222)
at
org
.drools
.workflow
.instance
.impl
.WorkflowProcessInstanceImpl
.signalEvent(WorkflowProcessInstanceImpl.java:258)
at
org
.drools
.process
.instance
.impl
.DefaultWorkItemManager.completeWorkItem(DefaultWorkItemManager.java:96)
at com.jsi.inactivity.DroolsTest$1.executeWorkItem(DroolsTest.java:40)
17 years, 2 months
Facing severe issues while using Persistence
by Umesh Wankhede
Hi
While using workflow persistence feature (with human task component), I
am having quite a few problems. When I use default db (H2), I get
ConstraintViolationException [1]. Since I have to ultimately integrate
with Oracle, I modify the config files to point to Oracle. But with that
I started getting lot of other issues, like invalid column names (size,
date), invalid table name (Comment), SQLGrammarException, etc[2] (This
is serious problem, if you use Oracle!)
I am struggling for quite a few days to get this work, but no success,
any help would be greatly appreciated.
I am attaching the source code also[3].
[1]db-h2-errors.log
[2] db-oracle-errors.log
[3] RuleFlowTest.java, ruleflow.rf
Regds
Umesh
Legal Notice: This transmission, including any attachments, is confidential, proprietary, and may be privileged. It is intended solely for
the intended recipient. If you are not the intended recipient, you have received this transmission in error and you are hereby advised that any
review, disclosure, copying, distribution, or use of this transmission, or any of the information included therein, is unauthorized and strictly
prohibited. If you have received this transmission in error, please immediately notify the sender by reply and permanently delete all copies of
this transmission and its attachments
17 years, 2 months
Writing rules using java from template
by Meny Kobel
Hi,
Any updates regarding this subject?
I have the same problem and can't find a solution.
Like newbie I need to read varying rules from DB and transform them to
drools language.
Thanks,
Meny
17 years, 2 months
stateful knowledge session and thread safety
by Michal Bali
Hi,
I am trying to find out how to properly interact with one stateful knowledge
session from multiple concurrent threads. As far as I know the session is
not thread safe.
Is the BatchExecutor interface meant for this task?
Thanking you in advance.
Best Regards,
Michal
17 years, 2 months
Drools Boot Camp / share room
by Mauricio Salatino
I'm trying to get the money to go but I have a limited budget for hotel :)
and I don't care to share a room with another drools guy!
Just let me know if you are in the same situation than I or if you just
don't mind to share the room and help this poor drooler!
Thanks! Hope to see you all in San Francisco!
--
- Salatino Mauricio -
17 years, 2 months
How to write below rule using Guvnor ( Invoice and Line Item scenario )
by Ashish Soni
Hi All ,
I am trying to write below rule in Guvnor Guided Editor but not able to do
so , Any help or suggestion will be appreciated -
Let say i have a Invoice Object which contains collection of Line Items
Class Invoice
{
private Collection<LineItem> lineItems;
}
Class LineItem
{
private double grossAmount;
}
Now i want to write a rule on Invoice object so that when ever there is only
one LineItem in the collection and the gross amount is greater then $100
then split the lineitem in two with setting equal gross amount in each Line
Item i.e after the rule execution the Collection of the LineItem should
contain two line item object with equal gross amount .
Please let me know how can i create this rule using Guvnor guided editor.
Regards,
Ashish
17 years, 2 months
