[jboss-svn-commits] JBL Code SVN: r33588 - 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: hzbarcea
Date: 2010-06-22 00:51:57 -0400 (Tue, 22 Jun 2010)
New Revision: 33588

Added:
   labs/jbossrules/trunk/drools-pipeline/drools-camel/src/main/java/org/drools/camel/component/DroolsRouteBuilder.java
Modified:
   labs/jbossrules/trunk/drools-pipeline/drools-camel/src/test/java/org/drools/camel/component/CamelEndpointWithMarshallersTest.java
Log:
JBRULES-2347: Drools Pipeline integration with Camel
- added a DroolsRouteBuilder that uses a drools routePolicy by default.



Added: labs/jbossrules/trunk/drools-pipeline/drools-camel/src/main/java/org/drools/camel/component/DroolsRouteBuilder.java
===================================================================
--- labs/jbossrules/trunk/drools-pipeline/drools-camel/src/main/java/org/drools/camel/component/DroolsRouteBuilder.java	                        (rev 0)
+++ labs/jbossrules/trunk/drools-pipeline/drools-camel/src/main/java/org/drools/camel/component/DroolsRouteBuilder.java	2010-06-22 04:51:57 UTC (rev 33588)
@@ -0,0 +1,47 @@
+/*
+ *  Licensed under the Apache License, Version 2.0 (the "License");
+ *  you may not use this file except in compliance with the License.
+ *  You may obtain a copy of the License at
+ * 
+ *       http://www.apache.org/licenses/LICENSE-2.0
+ * 
+ *  Unless required by applicable law or agreed to in writing, software
+ *  distributed under the License is distributed on an "AS IS" BASIS,
+ *  WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ *  See the License for the specific language governing permissions and
+ *  limitations under the License.
+ *  under the License.
+ */
+
+package org.drools.camel.component;
+
+import org.apache.camel.Endpoint;
+import org.apache.camel.builder.RouteBuilder;
+import org.apache.camel.model.RouteDefinition;
+
+public abstract class DroolsRouteBuilder extends RouteBuilder {
+    @Override
+    public RouteDefinition from(String uri) {
+        return super.from(uri).routePolicy(new DroolsClassloaderPolicy());
+    }
+    
+    @Override
+    public RouteDefinition fromF(String uri, Object... args) {
+        return super.fromF(uri, args).routePolicy(new DroolsClassloaderPolicy());
+    }
+
+    @Override
+    public RouteDefinition from(Endpoint endpoint) {
+        return super.from(endpoint).routePolicy(new DroolsClassloaderPolicy());
+    }
+
+    @Override
+    public RouteDefinition from(String... uris) {
+        return super.from(uris).routePolicy(new DroolsClassloaderPolicy());
+    }
+        
+    @Override
+    public RouteDefinition from(Endpoint... endpoints) {
+        return super.from(endpoints).routePolicy(new DroolsClassloaderPolicy());
+    }
+}

Modified: labs/jbossrules/trunk/drools-pipeline/drools-camel/src/test/java/org/drools/camel/component/CamelEndpointWithMarshallersTest.java
===================================================================
--- labs/jbossrules/trunk/drools-pipeline/drools-camel/src/test/java/org/drools/camel/component/CamelEndpointWithMarshallersTest.java	2010-06-22 03:59:47 UTC (rev 33587)
+++ labs/jbossrules/trunk/drools-pipeline/drools-camel/src/test/java/org/drools/camel/component/CamelEndpointWithMarshallersTest.java	2010-06-22 04:51:57 UTC (rev 33588)
@@ -148,11 +148,11 @@
 
     @Override
     protected RouteBuilder createRouteBuilder() throws Exception {
-        return new RouteBuilder() {
+        return new DroolsRouteBuilder() {
             public void configure() throws Exception {
-                from("direct:test-with-session").routePolicy(new DroolsClassloaderPolicy()).unmarshal("drools-xstream").to("drools:node/ksession1").marshal("drools-xstream");
-                from("direct:test-with-session-json").routePolicy(new DroolsClassloaderPolicy()).unmarshal("drools-json").to("drools:node/ksession1").marshal("drools-json" );
-                from("direct:test-no-session").routePolicy(new DroolsClassloaderPolicy()).unmarshal("drools-xstream").to( "drools:node").marshal("drools-xstream");
+                from("direct:test-with-session").unmarshal("drools-xstream").to("drools:node/ksession1").marshal("drools-xstream");
+                from("direct:test-with-session-json").unmarshal("drools-json").to("drools:node/ksession1").marshal("drools-json" );
+                from("direct:test-no-session").unmarshal("drools-xstream").to( "drools:node").marshal("drools-xstream");
             }
         };
     }