JMS – a new fact provider for Drools via Pipeline
The Drools Pipeline is a great tool that allows to put facts into the rule engine from the outside world. Currently supported stores are JMS queues and topics and text files. The format of the payload is almost free to choose, since out of the box you can use JAXB, XStream and the powerful Smooks transformer to convert your data into facts, which the rule engine is able to consume.
This article explains how to use Pipelines.
Labels: Guvnor, JBoss Rules, Pipeline
posted by Jaroslaw Kijanowski @ 7:08 PM
4 Comments
4 Comments:
Nice post Jarosław.
Your article uses Smooks to bind CSV records into Java Objects. Thought you might be interested to know that we have made it easier to do this in Smooks v1.2, either through the XML config or the new programmatic config: http://www.smooks.org/mediawiki/index.php?title=V1.2:Smooks_v1.2_User_Guide#Binding_CSV_Records_to_Java
Sorry... the link was screwed there :)
Try again: Binding CSV Records to Java
Hey Tom,
thanks! Used 1.2 and this simplified config works just fine :)
<?xml version='1.0' encoding='UTF-8'?>
<smooks-resource-list xmlns="http://www.milyn.org/xsd/smooks-1.1.xsd"
xmlns:csv="http://www.milyn.org/xsd/smooks/csv-1.2.xsd">
<csv:reader fields="name,surname,age,type,family">
<csv:singleBinding beanId="person"
class="eu.kijanowski.drools.pipeline.model.Person" />
</csv:reader>
</smooks-resource-list>
Nice Article on drools Pipeline.
In our project we are using tibco as jms provider.I am facing the issue while receiving events from the pipeline.
At the below line i am getting facing an issue.
Service messenger = PipelineFactory.newJmsMessenger(entry, props, destinationName, null);
My tibco jms related properties object is as follows.
props.setProperty(Context.INITIAL_CONTEXT_FACTORY, "com.tibco.tibjms.naming.TibjmsInitialContextFactory");
props.setProperty(Context.URL_PKG_PREFIXES, "com.tibco.tibjms.naming");
props.setProperty(Context.PROVIDER_URL, "tibjmsnaming://10.76.85.216:7222");
String destinationName = "queue/DIAG1_vmware-ucs-1-v02_routing";
i am getting the following issue:
Caused by: javax.naming.NameNotFoundException: Name not found: 'ConnectionFactory'
Please help me in resolving the issue.
Post a Comment
Subscribe to Post Comments [Atom]
<< Home