[jboss-svn-commits] JBL Code SVN: r32519 - in labs/jbossrules/trunk/drools-pipeline/drools-camel/src: test/java/org/drools/camel/component and 1 other directory.

[jboss-svn-commits at lists.jboss.org]

Author: lucazamador
Date: 2010-04-12 10:31:05 -0400 (Mon, 12 Apr 2010)
New Revision: 32519

Modified:
   labs/jbossrules/trunk/drools-pipeline/drools-camel/src/main/java/org/drools/camel/component/DroolsXStreamDataFormat.java
   labs/jbossrules/trunk/drools-pipeline/drools-camel/src/test/java/org/drools/camel/component/CamelEndpointWithJaxbTest.java
Log:
fixed camel test.

Modified: labs/jbossrules/trunk/drools-pipeline/drools-camel/src/main/java/org/drools/camel/component/DroolsXStreamDataFormat.java
===================================================================
--- labs/jbossrules/trunk/drools-pipeline/drools-camel/src/main/java/org/drools/camel/component/DroolsXStreamDataFormat.java	2010-04-12 14:28:07 UTC (rev 32518)
+++ labs/jbossrules/trunk/drools-pipeline/drools-camel/src/main/java/org/drools/camel/component/DroolsXStreamDataFormat.java	2010-04-12 14:31:05 UTC (rev 32519)
@@ -23,7 +23,9 @@
 import org.apache.camel.Exchange;
 import org.apache.camel.spi.DataFormat;
 import org.drools.builder.DirectoryLookupFactoryService;
+import org.drools.command.impl.CommandBasedStatefulKnowledgeSession;
 import org.drools.grid.ExecutionNode;
+import org.drools.impl.KnowledgeBaseImpl;
 import org.drools.impl.StatefulKnowledgeSessionImpl;
 import org.drools.impl.StatelessKnowledgeSessionImpl;
 import org.drools.reteoo.ReteooRuleBase;
@@ -111,6 +113,8 @@
 			    xstream.setClassLoader(cl);
 			} else if (executor instanceof StatelessKnowledgeSessionImpl) {
 			    cl = ((ReteooRuleBase) ((StatelessKnowledgeSessionImpl) executor).getRuleBase()).getRootClassLoader();
+			} else if (executor instanceof CommandBasedStatefulKnowledgeSession) {
+				cl = ((ReteooRuleBase) ((KnowledgeBaseImpl)((CommandBasedStatefulKnowledgeSession) executor).getKnowledgeBase()).getRuleBase()).getRootClassLoader();
 			} else {
 			    throw new IllegalArgumentException("Unable to set ClassLoader on " + executor);
 			}
@@ -127,30 +131,4 @@
 		}
     }
 
-//    private Document processTranslate(Object object) {
-//        // Create a DOM builder and parse the fragment
-//        DocumentBuilderFactory factory = DocumentBuilderFactory.newInstance();
-//        Document d = null;
-//        try {
-//            d = factory.newDocumentBuilder().parse((InputSource) null);
-//        } catch (Exception e) {
-//        }
-//        try {
-//            if (object instanceof String) {
-//                d = factory.newDocumentBuilder().parse(new InputSource(new StringReader((String) object)));
-//            } else if (object instanceof Reader) {
-//                d = factory.newDocumentBuilder().parse(new InputSource((Reader) object));
-//            } else if (object instanceof InputStream) {
-//                d = factory.newDocumentBuilder().parse((InputStream) object);
-//            } else if (object instanceof Resource) {
-//                d = factory.newDocumentBuilder().parse(new InputSource(((Resource) object).getReader()));
-//            } else {
-//                throw new IllegalArgumentException("signal object must be instance of InputStream or Resource");
-//            }
-//        } catch (Exception e) {
-//            // handleException(this, object, e);
-//            e.printStackTrace();
-//        }
-//        return d;
-//    }
 }
\ No newline at end of file

Modified: labs/jbossrules/trunk/drools-pipeline/drools-camel/src/test/java/org/drools/camel/component/CamelEndpointWithJaxbTest.java
===================================================================
--- labs/jbossrules/trunk/drools-pipeline/drools-camel/src/test/java/org/drools/camel/component/CamelEndpointWithJaxbTest.java	2010-04-12 14:28:07 UTC (rev 32518)
+++ labs/jbossrules/trunk/drools-pipeline/drools-camel/src/test/java/org/drools/camel/component/CamelEndpointWithJaxbTest.java	2010-04-12 14:31:05 UTC (rev 32519)
@@ -104,7 +104,7 @@
 		assertNotNull(resp.getValue("hadrian"));
 	}
 	
-	public void FIXMEtestSessionModify() throws Exception {
+	public void testSessionModify() throws Exception {
 		String cmd = "";
 		cmd += "<batch-execution lookup='ksession1'>\n";
 		cmd += "   <modify factHandle='" + handle + "'>\n";