[ http://jira.jboss.com/jira/browse/JBRULES-959?page=comments#action_12367263 ] Gilles Dubuc commented on JBRULES-959: -------------------------------------- /* * BOBOMessage.java THIS IS THE FACT CLASS USED IN THIS TEST * * Created on April 5, 2007, 12:08 PM * * SMS Central 2007 */ package com.smsc.mitto.rules.client; import java.io.Serializable; import javax.jms.Connection; import javax.jms.DeliveryMode; import javax.jms.MessageProducer; import javax.jms.Queue; import javax.jms.QueueConnectionFactory; import javax.jms.Session; import javax.jms.TextMessage; import javax.naming.Context; import javax.naming.InitialContext; /** * A test class to act as a fact given to rules * * @author Gilles Dubuc */ public final class BOBOMessage implements Serializable { private String message; /** * Getter for the String message contained by the BOBOMessage object * @return The message String * @see #setMessage */ public String getMessage() { return this.message; } /** * Setter for the String message contained by the BOBOMessage object * @param message The new message String to be stored by the BOBOMessage object * @see #getMessage */ public void setMessage(final String message) { this.message = message; } /** * Send the message to a given queue * @param queuename The name of the queue the message needs to be redirected to */ public void sendToQueue(String queuename) { try { Context ctx = new InitialContext(); QueueConnectionFactory connectionFactory = (QueueConnectionFactory) ctx.lookup("QueueConnectionFactory"); Connection localconnection = connectionFactory.createConnection(); localconnection.start(); Session localsession = localconnection.createSession(false, Session.AUTO_ACKNOWLEDGE); Queue destination = (Queue) ctx.lookup("queue/" + queuename); MessageProducer producer = localsession.createProducer(destination); producer.setDeliveryMode(DeliveryMode.PERSISTENT); producer.setTimeToLive(3600000); TextMessage textmessage = localsession.createTextMessage(this.message); producer.send(textmessage); System.out.println("The message received by " + Thread.currentThread().getId() + " has been redirected to queue " + queuename + " according to the rule"); localsession.close(); localconnection.close(); } catch (Exception ex) { ex.printStackTrace(); } } } -- This message is automatically generated by JIRA. - If you think it was sent incorrectly contact one of the administrators: http://jira.jboss.com/jira/secure/Administrators.jspa - For more information on JIRA, see: http://www.atlassian.com/software/jira

[ http://jira.jboss.com/jira/browse/JBRULES-959?page=comments#action_12367265 ] Gilles Dubuc commented on JBRULES-959: -------------------------------------- // Method called to retrieve from the cache if available or recompile and put in the cache otherwise public RuleBase getGroupRuleBase(RuleGroup rulegroup) { String ruleIdString = rulegroup.getId().toString(); logger.debug("RuleService - Asked to provide rulebase for group with id=" + ruleIdString); RuleBase ruleBase = null; boolean nullCache = false; if (rulesCache == null || this.cacheDisabled) nullCache = true; else { nullCache = false; Object retrieved = null; try { retrieved = rulesCache.get("/mitto/rules/group/", rulegroup.getId()); } catch (CacheException e) { logger.warn("Could not find rule group with id=" + ruleIdString + " in the cache", e); retrieved = null; } ruleBase = (retrieved == null)?null:(RuleBase) retrieved; } if (EntityRule.isGroupInvalidated(rulegroup) || ruleBase == null) { logger.debug("RuleService - Generate rulebase for rule group with id=" + ruleIdString); Reader dsl = new StringReader(rulegroup.getPackage().getDSL()); Reader drl = new StringReader(EntityRule.getDRLByGroup(rulegroup)); logger.debug("DRL of the group with id=" + ruleIdString + ": " + EntityRule.getDRLByGroup(rulegroup)); /*try { logger.debug("Expanded DRL of the rule with id="+ ruleIdString + ":" + getExpandedDRL(EntityRule.getDRLByGroup(rulegroup), dsl)); } catch (DroolsParserException e) { logger.error("Drools parsing error", e); } dsl = new StringReader(rulegroup.getPackage().getDSL());*/ PackageBuilderConfiguration pkgBuilderCfg = new PackageBuilderConfiguration(); //pkgBuilderCfg.setCompiler(PackageBuilderConfiguration.JANINO); pkgBuilderCfg.setCompiler(PackageBuilderConfiguration.ECLIPSE); PackageBuilder builder = new PackageBuilder(pkgBuilderCfg); try { builder.addPackageFromDrl(drl, dsl); } catch (DroolsParserException e) { logger.warn("Drools could not parse the DRL for rule group with id=" + ruleIdString, e); } catch (IOException e) { logger.warn("IO error when Drools could not parse the DRL for rule group with id=" + ruleIdString, e); } if (builder.hasErrors()) logger.error("Drools errors happened when trying to compile the rule group with id=" + ruleIdString + ":" + builder.getErrors().toString()); Package pkg = builder.getPackage(); ruleBase = RuleBaseFactory.newRuleBase(); try { ruleBase.addPackage( pkg ); } catch (Exception e) { logger.error("Drools error happened when trying to add the package to the Rulebase for rule group with id=" + ruleIdString, e); } if (!nullCache) { try { rulesCache.put("/mitto/rules/group/", rulegroup.getId(), ruleBase); } catch (CacheException ex) { logger.error("Cache error when tryin to put rule group with id= " + ruleIdString + " into the cache", ex); } } EntityRule.setGroupInvalidated(rulegroup, false); } else logger.debug("RuleService - Found rulebase in cache for rule group with id=" + ruleIdString); return ruleBase; } -- This message is automatically generated by JIRA. - If you think it was sent incorrectly contact one of the administrators: http://jira.jboss.com/jira/secure/Administrators.jspa - For more information on JIRA, see: http://www.atlassian.com/software/jira

[ http://jira.jboss.com/jira/browse/JBRULES-959?page=all ] Edson Tirelli reassigned JBRULES-959: ------------------------------------- Assignee: Edson Tirelli (was: Michael Neale) -- This message is automatically generated by JIRA. - If you think it was sent incorrectly contact one of the administrators: http://jira.jboss.com/jira/secure/Administrators.jspa - For more information on JIRA, see: http://www.atlassian.com/software/jira

[ http://jira.jboss.com/jira/browse/JBRULES-959?page=all ] Edson Tirelli updated JBRULES-959: ---------------------------------- Fix Version/s: FUTURE (was: 4.0.0.MR4) This will be investigated after we have 4.0 stable. -- This message is automatically generated by JIRA. - If you think it was sent incorrectly contact one of the administrators: http://jira.jboss.com/jira/secure/Administrators.jspa - For more information on JIRA, see: http://www.atlassian.com/software/jira