You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@servicemix.apache.org by ks...@apache.org on 2015/05/27 00:14:08 UTC
[3/3] servicemix git commit: SM-2548: Provide CXF Rest Service
example for Drools 6 (closes #28)
SM-2548: Provide CXF Rest Service example for Drools 6 (closes #28)
Thanks to Grzegorz Halajko for the pull request!!!
Project: http://git-wip-us.apache.org/repos/asf/servicemix/repo
Commit: http://git-wip-us.apache.org/repos/asf/servicemix/commit/8ae57000
Tree: http://git-wip-us.apache.org/repos/asf/servicemix/tree/8ae57000
Diff: http://git-wip-us.apache.org/repos/asf/servicemix/diff/8ae57000
Branch: refs/heads/master
Commit: 8ae57000027797d0ca2ab4cef7b78b90a2023db4
Parents: f644027
Author: Grzegorz Halajko <gh...@linuxpolska.pl>
Authored: Tue May 26 23:26:32 2015 +0200
Committer: Krzysztof Sobkowiak <kr...@gmail.com>
Committed: Wed May 27 00:03:34 2015 +0200
----------------------------------------------------------------------
.../src/main/filtered-resources/examples.xml | 7 +
.../drools/drools-camel-cxf-server/README.txt | 136 +++++++++++++++++++
examples/drools/drools-camel-cxf-server/pom.xml | 104 ++++++++++++++
.../drools/camel/cxf/server/model/Customer.java | 79 +++++++++++
.../camel/cxf/server/model/CustomerType.java | 22 +++
.../cxf/server/osgi/CommandMessageBodyRW.java | 74 ++++++++++
.../server/osgi/DebugAgendaEventListener.java | 132 ++++++++++++++++++
.../osgi/DebugRuleRuntimeEventListener.java | 61 +++++++++
.../drools/camel/cxf/server/osgi/Utils.java | 59 ++++++++
.../OSGI-INF/blueprint/camel-client.xml | 78 +++++++++++
.../OSGI-INF/blueprint/camel-server.xml | 58 ++++++++
.../OSGI-INF/blueprint/kmodule-blueprint.xml | 44 ++++++
.../src/main/resources/rule/customer-score.drl | 48 +++++++
.../src/test/resources/batch-test-request.xml | 14 ++
.../src/test/resources/test-request.xml | 6 +
examples/drools/pom.xml | 1 +
.../itests/Drools6IntegrationTests.scala | 13 ++
17 files changed, 936 insertions(+)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/servicemix/blob/8ae57000/assembly/src/main/filtered-resources/examples.xml
----------------------------------------------------------------------
diff --git a/assembly/src/main/filtered-resources/examples.xml b/assembly/src/main/filtered-resources/examples.xml
index 8bfe111..4cbd587 100644
--- a/assembly/src/main/filtered-resources/examples.xml
+++ b/assembly/src/main/filtered-resources/examples.xml
@@ -177,4 +177,11 @@
<bundle>mvn:org.apache.servicemix.examples/drools-spring/${version}</bundle>
</feature>
+ <feature name="examples-drools-camel-cxf-server" version="${version}" resolver="(obr)">
+ <feature version="${drools6.version}">kie-aries-blueprint</feature>
+ <feature version="${drools6.version}">kie-camel</feature>
+ <feature version="${camel.version}">camel-xstream</feature>
+ <bundle>mvn:org.apache.servicemix.examples/drools-camel-cxf-server/${version}</bundle>
+ </feature>
+
</features>
http://git-wip-us.apache.org/repos/asf/servicemix/blob/8ae57000/examples/drools/drools-camel-cxf-server/README.txt
----------------------------------------------------------------------
diff --git a/examples/drools/drools-camel-cxf-server/README.txt b/examples/drools/drools-camel-cxf-server/README.txt
new file mode 100644
index 0000000..aeb6cae
--- /dev/null
+++ b/examples/drools/drools-camel-cxf-server/README.txt
@@ -0,0 +1,136 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements. See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You 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.
+ */
+
+Drools 6 Simple Example
+==========================
+
+Purpose
+-------
+This example will show you how to use Drools 6 inside Apache ServiceMix and how to
+use rule engine in low level.
+
+
+
+Prerequisites for Running the Example
+-------------------------------------
+1. You must have the following installed on your machine:
+
+ - JDK 1.6 or higher
+
+ - Maven 3.0.2 or higher (for building)
+
+ For more information, see the README in the top-level examples
+ directory.
+
+2. Start ServiceMix by running the following command:
+
+ <servicemix_home>/bin/servicemix (on UNIX)
+ <servicemix_home>\bin\servicemix (on Windows)
+
+
+Running the Example
+-------------------
+To install and run the example where you build the example bundle
+yourself, complete the following steps:
+
+1. Before being able to run this example, you have to install some additional
+ features into the container first to add support for the Drools 6.
+
+ feature:install kie-aries-blueprint
+ feature:install kie-camel
+ feature:install camel-xstream
+
+2. Build the example by opening a command prompt, changing directory to
+ examples/drools/drools-simple (this example) and entering the following Maven
+ command:
+
+ mvn clean install
+
+ If all of the required OSGi bundles are available in your local Maven
+ repository, the example will build very quickly. Otherwise it may
+ take some time for Maven to download everything it needs.
+
+ The mvn install command builds the example deployment bundle and
+ copies it to your local Maven repository and to the target directory
+ of this example.
+
+3. Install the example by entering the following command in
+ the ServiceMix console:
+
+ bundle:install -s mvn:org.apache.servicemix.examples/drools-camel-cxf-server/${project.version}
+
+4. Once the bundle has been started, you will see on console logs from rule engine.
+
+drools-camel-cxf-server - 6.0.0.SNAPSHOT | objectInserted ==>[ObjectInsertedEventImpl:
+getFactHandle()=[fact 0:1:109283499:109283499:1:DEFAULT:NON_TRAIT:
+Customer [salary=3955, type=null]], getObject()=Customer [salary=3955, type=null],
+getKnowledgeRuntime()=org.drools.core.impl.StatefulKnowledgeSessionImpl@45a5e94a, getPropagationContext()=PhreakPropagationContext
+[entryPoint=EntryPoint::DEFAULT, factHandle=[fact 0:1:109283499:109283499:1:DEFAULT:NON_TRAIT:Customer
+[salary=3955, type=null]], leftTuple=null, originOffset=-1, propagationNumber=2, rule=null, type=0]]
+
+DroolsRestResult Exchange[ExchangePattern: InOut, BodyType: String,
+Body: <?xml version='1.0' encoding='UTF-8'?>
+ <execution-results>
+ <result identifier="customer">
+ <org.apache.servicemix.examples.drools.simple.model.Customer>
+ <salary>3955</salary>
+ <type>NORMAL</type>
+ </org.apache.servicemix.examples.drools.simple.model.Customer>
+ </result>
+ <fact-handle identifier="customer" external-form="0:1:878677865:878677865:2:DEFAULT:NON_TRAIT"/>
+ </execution-results>]
+
+ Timer on camel route call rest client procedure. Via rest service facts it's inserted to work memory
+ and in logs you can saw drools engine activity
+
+5. You can use a command-line utility, such as curl or Wget, to make the invocations.
+ For example, try using curl as follows:
+
+ #
+ # Single fact execution:
+ #
+ curl -X POST -T src/test/resources/test-request.xml -H "Content-Type: text/plain" http://localhost:8181/cxf/rest/execute
+
+ #
+ # Batch execution (multi facts insert):
+ #
+ curl -X POST -T src/test/resources/batch-test-request.xml -H "Content-Type: text/plain" http://localhost:8181/cxf/rest/execute
+
+Stopping and Uninstalling the Example
+-------------------------------------
+First, find the bundle id for the deployed example bundle by doing
+
+ osgi:list
+
+and looking for a line that looks like this one
+
+229 | Active | 80 | | Apache ServiceMix :: Examples :: Drools :: Camel CXF Server
+
+In the above case, the bundle id would be 229
+
+
+To stop the example, enter the following command in the ServiceMix
+console:
+
+ bundle:stop <bundle_id>
+
+
+To uninstall the example, enter one of the following commands in
+the ServiceMix console:
+
+ bundle:uninstall <bundle_id>
+
\ No newline at end of file
http://git-wip-us.apache.org/repos/asf/servicemix/blob/8ae57000/examples/drools/drools-camel-cxf-server/pom.xml
----------------------------------------------------------------------
diff --git a/examples/drools/drools-camel-cxf-server/pom.xml b/examples/drools/drools-camel-cxf-server/pom.xml
new file mode 100644
index 0000000..adf2d19
--- /dev/null
+++ b/examples/drools/drools-camel-cxf-server/pom.xml
@@ -0,0 +1,104 @@
+<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
+ xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
+ <!--
+
+ Licensed to the Apache Software Foundation (ASF) under one or more
+ contributor license agreements. See the NOTICE file distributed with
+ this work for additional information regarding copyright ownership.
+ The ASF licenses this file to You 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.
+ -->
+ <modelVersion>4.0.0</modelVersion>
+ <parent>
+ <groupId>org.apache.servicemix.examples</groupId>
+ <artifactId>drools</artifactId>
+ <version>6.0.0-SNAPSHOT</version>
+ </parent>
+
+ <artifactId>drools-camel-cxf-server</artifactId>
+ <name>Apache ServiceMix :: Examples :: Drools :: Camel CXF Server</name>
+ <packaging>bundle</packaging>
+
+ <properties>
+ <osgi.private.package>
+ org.apache.servicemix.examples.drools.camel.cxf.server.osgi,
+ org.apache.servicemix.examples.drools.camel.cxf.server.model</osgi.private.package>
+ <osgi.import.package>
+ org.osgi.service.blueprint,
+ org.slf4j;version="[1.6,2)",
+ org.kie.jax.rs;version="[6.0,7.0)",
+ org.kie.camel.component;version="[6.0,7.0)",
+ org.kie.api.event.rule;version="[6.0,7.0)",
+ org.kie.api.command;version="[6.0,7.0)",
+ org.kie.aries.blueprint.factorybeans;version="[6.0,7.0)",
+ org.apache.camel;version="[2.15,2.16)",
+
+ org.kie.internal.command;version="[6.0,7)",
+
+ org.kie.internal.runtime.helper;version="[6.0,7)",
+ org.drools.core.runtime.impl;version="[6.0,7)",
+ org.drools.core.runtime.rule.impl;version="[6.0,7)",
+ org.drools.core.command.runtime.process;version="[6.0,7)",
+ org.drools.core.common;version="[6.0,7)",
+ org.drools.core.command.runtime;version="[6.0,7)",
+ org.drools.core.command.runtime.rule;version="[6.0,7)",
+ org.drools.core.impl;version="[6.0,7)",
+ org.drools.core.runtime.help.impl;version="[6.0,7)",
+ com.thoughtworks.xstream;version="1.4",
+ javax.ws.rs.ext,
+ javax.ws.rs.core,
+ javax.ws.rs
+ </osgi.import.package>
+ </properties>
+
+ <dependencies>
+
+ <dependency>
+ <groupId>org.kie</groupId>
+ <artifactId>kie-api</artifactId>
+ </dependency>
+
+ <dependency>
+ <groupId>org.kie</groupId>
+ <artifactId>kie-camel</artifactId>
+ </dependency>
+
+ <dependency>
+ <groupId>org.drools</groupId>
+ <artifactId>drools-compiler</artifactId>
+ </dependency>
+
+
+ <dependency>
+ <groupId>org.apache.camel</groupId>
+ <artifactId>camel-core</artifactId>
+ </dependency>
+
+ <dependency>
+ <groupId>org.apache.camel</groupId>
+ <artifactId>camel-cxf</artifactId>
+ </dependency>
+
+ </dependencies>
+
+
+ <build>
+ <plugins>
+ <plugin>
+ <groupId>org.apache.felix</groupId>
+ <artifactId>maven-bundle-plugin</artifactId>
+ </plugin>
+ </plugins>
+ </build>
+
+</project>
\ No newline at end of file
http://git-wip-us.apache.org/repos/asf/servicemix/blob/8ae57000/examples/drools/drools-camel-cxf-server/src/main/java/org/apache/servicemix/examples/drools/camel/cxf/server/model/Customer.java
----------------------------------------------------------------------
diff --git a/examples/drools/drools-camel-cxf-server/src/main/java/org/apache/servicemix/examples/drools/camel/cxf/server/model/Customer.java b/examples/drools/drools-camel-cxf-server/src/main/java/org/apache/servicemix/examples/drools/camel/cxf/server/model/Customer.java
new file mode 100644
index 0000000..98e2b5d
--- /dev/null
+++ b/examples/drools/drools-camel-cxf-server/src/main/java/org/apache/servicemix/examples/drools/camel/cxf/server/model/Customer.java
@@ -0,0 +1,79 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements. See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You 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.
+ */
+package org.apache.servicemix.examples.drools.camel.cxf.server.model;
+
+public class Customer {
+
+ /**
+ * Salary
+ */
+ private int salary;
+
+ /**
+ * IS VIP.
+ */
+ private CustomerType type;
+
+ /**
+ * Create customer with salary.
+ *
+ * @param salary
+ */
+ public Customer(int salary) {
+ this.salary = salary;
+ }
+
+ /**
+ * @return the salary
+ */
+ public int getSalary() {
+ return salary;
+ }
+
+ /**
+ * @return the type
+ */
+ public CustomerType getType() {
+ return type;
+ }
+
+ /**
+ * @param salary the salary to set
+ */
+ public void setSalary(int salary) {
+ this.salary = salary;
+ }
+
+ /**
+ * @param type the type to set
+ */
+ public void setType(CustomerType type) {
+ this.type = type;
+ }
+
+ /**
+ * @see Object#toString()
+ */
+ @Override
+ public String toString() {
+ StringBuilder builder = new StringBuilder();
+ builder.append("Customer [salary=").append(salary).append(", type=")
+ .append(type).append("]");
+ return builder.toString();
+ }
+
+}
http://git-wip-us.apache.org/repos/asf/servicemix/blob/8ae57000/examples/drools/drools-camel-cxf-server/src/main/java/org/apache/servicemix/examples/drools/camel/cxf/server/model/CustomerType.java
----------------------------------------------------------------------
diff --git a/examples/drools/drools-camel-cxf-server/src/main/java/org/apache/servicemix/examples/drools/camel/cxf/server/model/CustomerType.java b/examples/drools/drools-camel-cxf-server/src/main/java/org/apache/servicemix/examples/drools/camel/cxf/server/model/CustomerType.java
new file mode 100644
index 0000000..b969c67
--- /dev/null
+++ b/examples/drools/drools-camel-cxf-server/src/main/java/org/apache/servicemix/examples/drools/camel/cxf/server/model/CustomerType.java
@@ -0,0 +1,22 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements. See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You 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.
+ */
+package org.apache.servicemix.examples.drools.camel.cxf.server.model;
+
+
+public enum CustomerType {
+ POOR, NORMAL, VIP;
+}
http://git-wip-us.apache.org/repos/asf/servicemix/blob/8ae57000/examples/drools/drools-camel-cxf-server/src/main/java/org/apache/servicemix/examples/drools/camel/cxf/server/osgi/CommandMessageBodyRW.java
----------------------------------------------------------------------
diff --git a/examples/drools/drools-camel-cxf-server/src/main/java/org/apache/servicemix/examples/drools/camel/cxf/server/osgi/CommandMessageBodyRW.java b/examples/drools/drools-camel-cxf-server/src/main/java/org/apache/servicemix/examples/drools/camel/cxf/server/osgi/CommandMessageBodyRW.java
new file mode 100644
index 0000000..6889982
--- /dev/null
+++ b/examples/drools/drools-camel-cxf-server/src/main/java/org/apache/servicemix/examples/drools/camel/cxf/server/osgi/CommandMessageBodyRW.java
@@ -0,0 +1,74 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements. See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You 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.
+ */
+package org.apache.servicemix.examples.drools.camel.cxf.server.osgi;
+
+import java.io.IOException;
+import java.io.OutputStream;
+import java.lang.annotation.Annotation;
+import java.lang.reflect.Type;
+import javax.ws.rs.Consumes;
+import javax.ws.rs.WebApplicationException;
+import javax.ws.rs.core.MediaType;
+import javax.ws.rs.core.MultivaluedMap;
+import javax.ws.rs.ext.MessageBodyWriter;
+import javax.ws.rs.ext.Provider;
+
+import org.drools.core.runtime.help.impl.BatchExecutionHelperProviderImpl;
+import org.kie.api.command.Command;
+import org.kie.internal.runtime.helper.BatchExecutionHelperProvider;
+
+
+@Consumes("text/plain")
+@Provider
+public class CommandMessageBodyRW implements MessageBodyWriter<Command<?>> {
+
+ /**
+ * provider
+ */
+ private BatchExecutionHelperProvider provider = new BatchExecutionHelperProviderImpl();
+
+ /**
+ * getSize
+ */
+ @Override
+ public long getSize(Command<?> arg0, Class<?> arg1, Type arg2,
+ Annotation[] arg3, MediaType arg4) {
+ return -1;
+ }
+
+ /**
+ * isWriteable
+ */
+ @Override
+ public boolean isWriteable(Class<?> type, Type genericType,
+ Annotation[] arg2, MediaType arg3) {
+ return Command.class.isAssignableFrom(type);
+
+ }
+
+ /**
+ * writeTo
+ */
+ @Override
+ public void writeTo(Command<?> obj, Class<?> arg1, Type arg2,
+ Annotation[] arg3, MediaType arg4,
+ MultivaluedMap<String, Object> arg5, OutputStream out)
+ throws IOException, WebApplicationException {
+ provider.newXStreamMarshaller().toXML(obj, out);
+ }
+
+}
http://git-wip-us.apache.org/repos/asf/servicemix/blob/8ae57000/examples/drools/drools-camel-cxf-server/src/main/java/org/apache/servicemix/examples/drools/camel/cxf/server/osgi/DebugAgendaEventListener.java
----------------------------------------------------------------------
diff --git a/examples/drools/drools-camel-cxf-server/src/main/java/org/apache/servicemix/examples/drools/camel/cxf/server/osgi/DebugAgendaEventListener.java b/examples/drools/drools-camel-cxf-server/src/main/java/org/apache/servicemix/examples/drools/camel/cxf/server/osgi/DebugAgendaEventListener.java
new file mode 100644
index 0000000..bad7479
--- /dev/null
+++ b/examples/drools/drools-camel-cxf-server/src/main/java/org/apache/servicemix/examples/drools/camel/cxf/server/osgi/DebugAgendaEventListener.java
@@ -0,0 +1,132 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements. See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You 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.
+ */
+package org.apache.servicemix.examples.drools.camel.cxf.server.osgi;
+
+import org.kie.api.event.rule.AfterMatchFiredEvent;
+import org.kie.api.event.rule.AgendaEventListener;
+import org.kie.api.event.rule.AgendaGroupPoppedEvent;
+import org.kie.api.event.rule.AgendaGroupPushedEvent;
+import org.kie.api.event.rule.BeforeMatchFiredEvent;
+import org.kie.api.event.rule.MatchCancelledEvent;
+import org.kie.api.event.rule.MatchCreatedEvent;
+import org.kie.api.event.rule.RuleFlowGroupActivatedEvent;
+import org.kie.api.event.rule.RuleFlowGroupDeactivatedEvent;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+
+/**
+ * Drools 6 Rule Engine events logger.
+ */
+public class DebugAgendaEventListener implements AgendaEventListener {
+ /**
+ * Logger.
+ */
+ private static final Logger log = LoggerFactory
+ .getLogger(DebugAgendaEventListener.class);
+
+ /**
+ * @see AgendaEventListener#matchCreated(org.kie.api.event.rule.MatchCreatedEvent)
+ */
+ @Override
+ public void matchCreated(MatchCreatedEvent event) {
+ log.info("{}", event);
+
+ }
+
+ /**
+ * @see AgendaEventListener#matchCancelled(org.kie.api.event.rule.MatchCancelledEvent)
+ */
+ @Override
+ public void matchCancelled(MatchCancelledEvent event) {
+ log.info("{}", event);
+
+ }
+
+ /**
+ * @see AgendaEventListener#beforeMatchFired(org.kie.api.event.rule.BeforeMatchFiredEvent)
+ */
+ @Override
+ public void beforeMatchFired(BeforeMatchFiredEvent event) {
+ log.info("{}", event);
+
+ }
+
+ /**
+ * @see AgendaEventListener#afterMatchFired(org.kie.api.event.rule.AfterMatchFiredEvent)
+ */
+ @Override
+ public void afterMatchFired(AfterMatchFiredEvent event) {
+ log.info("{}", event);
+
+ }
+
+ /**
+ * @see AgendaEventListener#agendaGroupPopped(org.kie.api.event.rule.AgendaGroupPoppedEvent)
+ */
+ @Override
+ public void agendaGroupPopped(AgendaGroupPoppedEvent event) {
+ log.info("{}", event);
+
+ }
+
+ /**
+ * @see AgendaEventListener#agendaGroupPushed(org.kie.api.event.rule.AgendaGroupPushedEvent)
+ */
+ @Override
+ public void agendaGroupPushed(AgendaGroupPushedEvent event) {
+ log.info("{}", event);
+
+ }
+
+ /**
+ * @see AgendaEventListener#beforeRuleFlowGroupActivated(org.kie.api.event.rule.RuleFlowGroupActivatedEvent)
+ */
+ @Override
+ public void beforeRuleFlowGroupActivated(RuleFlowGroupActivatedEvent event) {
+ log.info("{}", event);
+
+ }
+
+ /**
+ * @see AgendaEventListener#afterRuleFlowGroupActivated(org.kie.api.event.rule.RuleFlowGroupActivatedEvent)
+ */
+ @Override
+ public void afterRuleFlowGroupActivated(RuleFlowGroupActivatedEvent event) {
+ log.info("{}", event);
+
+ }
+
+ /**
+ * @see AgendaEventListener#beforeRuleFlowGroupDeactivated(org.kie.api.event.rule.RuleFlowGroupDeactivatedEvent)
+ */
+ @Override
+ public void beforeRuleFlowGroupDeactivated(
+ RuleFlowGroupDeactivatedEvent event) {
+ log.info("{}", event);
+
+ }
+
+ /**
+ * @see AgendaEventListener#beforeRuleFlowGroupDeactivated(org.kie.api.event.rule.RuleFlowGroupDeactivatedEvent)
+ */
+ @Override
+ public void afterRuleFlowGroupDeactivated(
+ RuleFlowGroupDeactivatedEvent event) {
+ log.info("{}", event);
+
+ }
+}
http://git-wip-us.apache.org/repos/asf/servicemix/blob/8ae57000/examples/drools/drools-camel-cxf-server/src/main/java/org/apache/servicemix/examples/drools/camel/cxf/server/osgi/DebugRuleRuntimeEventListener.java
----------------------------------------------------------------------
diff --git a/examples/drools/drools-camel-cxf-server/src/main/java/org/apache/servicemix/examples/drools/camel/cxf/server/osgi/DebugRuleRuntimeEventListener.java b/examples/drools/drools-camel-cxf-server/src/main/java/org/apache/servicemix/examples/drools/camel/cxf/server/osgi/DebugRuleRuntimeEventListener.java
new file mode 100644
index 0000000..71a8229
--- /dev/null
+++ b/examples/drools/drools-camel-cxf-server/src/main/java/org/apache/servicemix/examples/drools/camel/cxf/server/osgi/DebugRuleRuntimeEventListener.java
@@ -0,0 +1,61 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements. See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You 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.
+ */
+package org.apache.servicemix.examples.drools.camel.cxf.server.osgi;
+
+import org.kie.api.event.rule.ObjectDeletedEvent;
+import org.kie.api.event.rule.ObjectInsertedEvent;
+import org.kie.api.event.rule.ObjectUpdatedEvent;
+import org.kie.api.event.rule.RuleRuntimeEventListener;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+
+/**
+ * Drools 6 Working memory events.
+ */
+public class DebugRuleRuntimeEventListener implements RuleRuntimeEventListener {
+ /**
+ * Logger.
+ */
+ private static final Logger log = LoggerFactory
+ .getLogger(DebugRuleRuntimeEventListener.class);
+
+ /**
+ * @see RuleRuntimeEventListener#objectInserted(ObjectInsertedEvent)
+ */
+ @Override
+ public void objectInserted(ObjectInsertedEvent event) {
+ log.info("objectInserted {}", event);
+ }
+
+ /**
+ * @see RuleRuntimeEventListener#objectUpdated(org.kie.api.event.rule.ObjectUpdatedEvent)
+ */
+ @Override
+ public void objectUpdated(ObjectUpdatedEvent event) {
+ log.info("objectUpdated {}", event);
+
+ }
+
+ /**
+ * @see RuleRuntimeEventListener#objectDeleted(org.kie.api.event.rule.ObjectDeletedEvent)
+ */
+ @Override
+ public void objectDeleted(ObjectDeletedEvent event) {
+ log.info("objectDeleted {}", event);
+ }
+
+}
http://git-wip-us.apache.org/repos/asf/servicemix/blob/8ae57000/examples/drools/drools-camel-cxf-server/src/main/java/org/apache/servicemix/examples/drools/camel/cxf/server/osgi/Utils.java
----------------------------------------------------------------------
diff --git a/examples/drools/drools-camel-cxf-server/src/main/java/org/apache/servicemix/examples/drools/camel/cxf/server/osgi/Utils.java b/examples/drools/drools-camel-cxf-server/src/main/java/org/apache/servicemix/examples/drools/camel/cxf/server/osgi/Utils.java
new file mode 100644
index 0000000..104a69e
--- /dev/null
+++ b/examples/drools/drools-camel-cxf-server/src/main/java/org/apache/servicemix/examples/drools/camel/cxf/server/osgi/Utils.java
@@ -0,0 +1,59 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements. See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You 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.
+ */
+package org.apache.servicemix.examples.drools.camel.cxf.server.osgi;
+
+import java.util.Arrays;
+import java.util.Random;
+
+import org.apache.servicemix.examples.drools.camel.cxf.server.model.Customer;
+import org.kie.api.command.Command;
+import org.kie.api.runtime.ExecutionResults;
+import org.kie.internal.command.CommandFactory;
+
+
+public class Utils {
+ /**
+ * Random
+ */
+ private static Random rand = new Random(12345);
+
+ /**
+ * Generate random customer
+ *
+ * @return
+ */
+ public Customer customer() {
+ return new Customer(rand.nextInt(9999));
+ }
+
+ /**
+ * Create commands for Drools engine.
+ *
+ * @param body {@link org.apache.camel.Exchange}
+ */
+ public Command<ExecutionResults> insertAndFireAll(final Customer body) {
+
+ Command<?> insert = CommandFactory.newInsert(body, "customer");
+
+ @SuppressWarnings("unchecked")
+ Command<ExecutionResults> batch = CommandFactory
+ .newBatchExecution(Arrays.asList(insert));
+
+ return batch;
+ }
+
+}
http://git-wip-us.apache.org/repos/asf/servicemix/blob/8ae57000/examples/drools/drools-camel-cxf-server/src/main/resources/OSGI-INF/blueprint/camel-client.xml
----------------------------------------------------------------------
diff --git a/examples/drools/drools-camel-cxf-server/src/main/resources/OSGI-INF/blueprint/camel-client.xml b/examples/drools/drools-camel-cxf-server/src/main/resources/OSGI-INF/blueprint/camel-client.xml
new file mode 100644
index 0000000..69f6d7b
--- /dev/null
+++ b/examples/drools/drools-camel-cxf-server/src/main/resources/OSGI-INF/blueprint/camel-client.xml
@@ -0,0 +1,78 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<!--
+ Licensed to the Apache Software Foundation (ASF) under one
+ or more contributor license agreements. See the NOTICE file
+ distributed with this work for additional information
+ regarding copyright ownership. The ASF licenses this file
+ to you 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.
+-->
+<blueprint xmlns="http://www.osgi.org/xmlns/blueprint/v1.0.0"
+ xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:jaxrs="http://cxf.apache.org/blueprint/jaxrs"
+ xmlns:cxf="http://camel.apache.org/schema/blueprint/cxf"
+ xmlns:cxf-core="http://cxf.apache.org/blueprint/core"
+ xsi:schemaLocation="
+http://www.osgi.org/xmlns/blueprint/v1.0.0 http://www.osgi.org/xmlns/blueprint/v1.0.0/blueprint.xsd
+http://cxf.apache.org/blueprint/jaxrs http://cxf.apache.org/schemas/blueprint/jaxrs.xsd
+http://camel.apache.org/schema/blueprint/cxf http://camel.apache.org/schema/cxf/camel-cxf-blueprint.xsd
+http://cxf.apache.org/blueprint/core http://cxf.apache.org/schemas/blueprint/core.xsd
+http://camel.apache.org/schema/blueprint http://camel.apache.org/schema/blueprint/camel-blueprint.xsd">
+
+ <!-- Rest Converter. Convert object extends by org.kie.api.command.Command
+ to string -->
+ <bean id="resultMessageProvider"
+ class="org.apache.servicemix.examples.drools.camel.cxf.server.osgi.CommandMessageBodyRW" />
+
+ <!-- Camel REST Client -->
+ <cxf:rsClient id="droolsRestClient" address="http://localhost:8181/cxf/rest"
+ serviceClass="org.kie.jax.rs.CommandExecutorImpl">
+ <cxf:providers>
+ <ref component-id="resultMessageProvider" />
+ </cxf:providers>
+ </cxf:rsClient>
+
+ <!-- Utils. -->
+ <bean id="customerUtil"
+ class="org.apache.servicemix.examples.drools.camel.cxf.server.osgi.Utils" />
+
+ <!-- Bean insert to Camel message configuration parameters
+ for cxf camel component -->
+ <bean id="preCxfrs" class="org.kie.camel.component.PreCxfrs" />
+
+ <!-- Bean trim response and convert request from InputStream to String -->
+ <bean id="postCxfrs" class="org.kie.camel.component.PostCxfrs" />
+
+ <!-- CAMEL -->
+ <camelContext id="camel-client"
+ xmlns="http://camel.apache.org/schema/blueprint">
+
+ <route id="route-to-rest">
+ <!-- Self-Timer -->
+ <from
+ uri="timer:restClientMock?fixedRate=true&period=30s&delay=5000" />
+ <process ref="preCxfrs" />
+ <!-- Create Customer with random salary -->
+ <bean method="customer" ref="customerUtil" />
+ <!-- Create KIE Commands -->
+ <bean method="insertAndFireAll" ref="customerUtil" />
+ <!-- Run CXF Rest client -->
+ <to uri="cxfrs:bean:droolsRestClient" />
+ <process ref="postCxfrs" />
+ <!-- The result it's printed in the logs. -->
+ <to uri="log:DroolsRestResult" />
+ </route>
+
+
+ </camelContext>
+
+</blueprint>
\ No newline at end of file
http://git-wip-us.apache.org/repos/asf/servicemix/blob/8ae57000/examples/drools/drools-camel-cxf-server/src/main/resources/OSGI-INF/blueprint/camel-server.xml
----------------------------------------------------------------------
diff --git a/examples/drools/drools-camel-cxf-server/src/main/resources/OSGI-INF/blueprint/camel-server.xml b/examples/drools/drools-camel-cxf-server/src/main/resources/OSGI-INF/blueprint/camel-server.xml
new file mode 100644
index 0000000..263096e
--- /dev/null
+++ b/examples/drools/drools-camel-cxf-server/src/main/resources/OSGI-INF/blueprint/camel-server.xml
@@ -0,0 +1,58 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<!--
+ Licensed to the Apache Software Foundation (ASF) under one
+ or more contributor license agreements. See the NOTICE file
+ distributed with this work for additional information
+ regarding copyright ownership. The ASF licenses this file
+ to you 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.
+-->
+<blueprint xmlns="http://www.osgi.org/xmlns/blueprint/v1.0.0"
+ xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:jaxrs="http://cxf.apache.org/blueprint/jaxrs"
+ xmlns:cxf="http://camel.apache.org/schema/blueprint/cxf"
+ xmlns:cxf-core="http://cxf.apache.org/blueprint/core"
+ xsi:schemaLocation="
+http://www.osgi.org/xmlns/blueprint/v1.0.0 http://www.osgi.org/xmlns/blueprint/v1.0.0/blueprint.xsd
+http://cxf.apache.org/blueprint/jaxrs http://cxf.apache.org/schemas/blueprint/jaxrs.xsd
+http://camel.apache.org/schema/blueprint/cxf http://camel.apache.org/schema/blueprint/cxf/camel-cxf.xsd
+http://cxf.apache.org/blueprint/core http://cxf.apache.org/schemas/blueprint/core.xsd">
+
+ <!-- Bean trim request string -->
+ <bean id="messageBodyReader" class="org.kie.jax.rs.CommandMessageBodyReader" />
+ <!-- Bean add support drools, catch rest request and run KIE Commands-->
+ <bean id="kiePolicy" class="org.kie.camel.component.KiePolicy" />
+
+ <!-- Apache Camel Rest Server -->
+ <cxf:rsServer id="restKieServer" address="/rest"
+ serviceClass="org.kie.jax.rs.CommandExecutorImpl">
+ <cxf:providers>
+ <ref component-id="messageBodyReader" />
+ </cxf:providers>
+ </cxf:rsServer>
+
+ <!-- CAMEL -->
+ <camelContext id="camel"
+ xmlns="http://camel.apache.org/schema/blueprint">
+ <!-- Route catch REST request and forward request to Kie Policy Bean-->
+ <route>
+ <from uri="cxfrs:bean:restKieServer" />
+ <policy ref="kiePolicy">
+ <unmarshal ref="xstream" />
+ <to uri="kie:simpleRuleKSession" />
+ <marshal ref="xstream" />
+ </policy>
+ </route>
+
+ </camelContext>
+
+</blueprint>
http://git-wip-us.apache.org/repos/asf/servicemix/blob/8ae57000/examples/drools/drools-camel-cxf-server/src/main/resources/OSGI-INF/blueprint/kmodule-blueprint.xml
----------------------------------------------------------------------
diff --git a/examples/drools/drools-camel-cxf-server/src/main/resources/OSGI-INF/blueprint/kmodule-blueprint.xml b/examples/drools/drools-camel-cxf-server/src/main/resources/OSGI-INF/blueprint/kmodule-blueprint.xml
new file mode 100644
index 0000000..b299caa
--- /dev/null
+++ b/examples/drools/drools-camel-cxf-server/src/main/resources/OSGI-INF/blueprint/kmodule-blueprint.xml
@@ -0,0 +1,44 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<!--
+ Licensed to the Apache Software Foundation (ASF) under one or more
+ contributor license agreements. See the NOTICE file distributed with
+ this work for additional information regarding copyright ownership.
+ The ASF licenses this file to You 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.
+-->
+<blueprint default-timeout="1000"
+ xmlns="http://www.osgi.org/xmlns/blueprint/v1.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
+ xmlns:kie="http://drools.org/schema/kie-aries-blueprint/1.0.0"
+ xsi:schemaLocation="
+ http://www.osgi.org/xmlns/blueprint/v1.0.0 http://www.osgi.org/xmlns/blueprint/v1.0.0
+ http://drools.org/schema/kie-aries-blueprint/1.0.0 http://drools.org/schema/kie-aries-blueprint/1.0.0">
+
+ <bean id="DebugAgendaEventListener"
+ class="org.apache.servicemix.examples.drools.camel.cxf.server.osgi.DebugAgendaEventListener" />
+ <bean id="DebugRuleRuntimeEventListener"
+ class="org.apache.servicemix.examples.drools.camel.cxf.server.osgi.DebugRuleRuntimeEventListener" />
+
+ <kie:eventListeners id="debugListeners">
+ <kie:agendaEventListener ref="DebugAgendaEventListener" />
+ <kie:ruleRuntimeEventListener ref="DebugRuleRuntimeEventListener" />
+ </kie:eventListeners>
+
+ <kie:kmodule id="id-kmodule">
+ <kie:kbase name="SimpleRuleKBase" default="true"
+ packages="rule">
+ <kie:ksession name="simpleRuleKSession" type="stateless"
+ listeners-ref="debugListeners" default="true">
+ </kie:ksession>
+ </kie:kbase>
+ </kie:kmodule>
+
+</blueprint>
http://git-wip-us.apache.org/repos/asf/servicemix/blob/8ae57000/examples/drools/drools-camel-cxf-server/src/main/resources/rule/customer-score.drl
----------------------------------------------------------------------
diff --git a/examples/drools/drools-camel-cxf-server/src/main/resources/rule/customer-score.drl b/examples/drools/drools-camel-cxf-server/src/main/resources/rule/customer-score.drl
new file mode 100644
index 0000000..bc1e3d7
--- /dev/null
+++ b/examples/drools/drools-camel-cxf-server/src/main/resources/rule/customer-score.drl
@@ -0,0 +1,48 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements. See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You 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.
+ */
+package rule;
+import org.apache.servicemix.examples.drools.camel.cxf.server.model.Customer;
+import org.apache.servicemix.examples.drools.camel.cxf.server.model.CustomerType;
+
+rule "Customer poor"
+when
+ $c : Customer( salary <= 1000, type == null)
+then
+ modify( $c ) {
+ setType(CustomerType.POOR)
+ };
+end
+
+
+rule "Customer NORMAL"
+when
+ $c : Customer( salary > 1000, salary <= 9000, type == null )
+then
+ modify( $c ) {
+ setType(CustomerType.NORMAL)
+ };
+end
+
+
+rule "Customer VIP"
+when
+ $c : Customer( salary > 9000, type == null)
+then
+ modify( $c ) {
+ setType(CustomerType.VIP)
+ };
+end
\ No newline at end of file
http://git-wip-us.apache.org/repos/asf/servicemix/blob/8ae57000/examples/drools/drools-camel-cxf-server/src/test/resources/batch-test-request.xml
----------------------------------------------------------------------
diff --git a/examples/drools/drools-camel-cxf-server/src/test/resources/batch-test-request.xml b/examples/drools/drools-camel-cxf-server/src/test/resources/batch-test-request.xml
new file mode 100644
index 0000000..2824888
--- /dev/null
+++ b/examples/drools/drools-camel-cxf-server/src/test/resources/batch-test-request.xml
@@ -0,0 +1,14 @@
+<batch-execution lookup="rule-num">
+ <insert out-identifier="cusomer1" return-object="true"
+ entry-point="DEFAULT">
+ <org.apache.servicemix.examples.drools.camel.cxf.server.model.Customer>
+ <salary>9000</salary>
+ </org.apache.servicemix.examples.drools.camel.cxf.server.model.Customer>
+ </insert>
+ <insert out-identifier="cusomer2" return-object="true"
+ entry-point="DEFAULT">
+ <org.apache.servicemix.examples.drools.camel.cxf.server.model.Customer>
+ <salary>1000</salary>
+ </org.apache.servicemix.examples.drools.camel.cxf.server.model.Customer>
+ </insert>
+</batch-execution>
http://git-wip-us.apache.org/repos/asf/servicemix/blob/8ae57000/examples/drools/drools-camel-cxf-server/src/test/resources/test-request.xml
----------------------------------------------------------------------
diff --git a/examples/drools/drools-camel-cxf-server/src/test/resources/test-request.xml b/examples/drools/drools-camel-cxf-server/src/test/resources/test-request.xml
new file mode 100644
index 0000000..0359247
--- /dev/null
+++ b/examples/drools/drools-camel-cxf-server/src/test/resources/test-request.xml
@@ -0,0 +1,6 @@
+<insert out-identifier="cusomer1" return-object="true"
+ entry-point="DEFAULT">
+ <org.apache.servicemix.examples.drools.camel.cxf.server.model.Customer>
+ <salary>9000</salary>
+ </org.apache.servicemix.examples.drools.camel.cxf.server.model.Customer>
+</insert>
\ No newline at end of file
http://git-wip-us.apache.org/repos/asf/servicemix/blob/8ae57000/examples/drools/pom.xml
----------------------------------------------------------------------
diff --git a/examples/drools/pom.xml b/examples/drools/pom.xml
index 97291cd..564c37f 100644
--- a/examples/drools/pom.xml
+++ b/examples/drools/pom.xml
@@ -76,6 +76,7 @@
<modules>
<module>drools-simple</module>
<module>drools-camel-blueprint</module>
+ <module>drools-camel-cxf-server</module>
<module>drools-spring</module>
</modules>
</project>
http://git-wip-us.apache.org/repos/asf/servicemix/blob/8ae57000/itests/src/test/scala/org/apache/servicemix/itests/Drools6IntegrationTests.scala
----------------------------------------------------------------------
diff --git a/itests/src/test/scala/org/apache/servicemix/itests/Drools6IntegrationTests.scala b/itests/src/test/scala/org/apache/servicemix/itests/Drools6IntegrationTests.scala
index 371e138..a197c37 100644
--- a/itests/src/test/scala/org/apache/servicemix/itests/Drools6IntegrationTests.scala
+++ b/itests/src/test/scala/org/apache/servicemix/itests/Drools6IntegrationTests.scala
@@ -117,3 +117,16 @@ class Drools6SpringExamplesTest extends Drools6IntegrationTests {
}
}
}
+
+/**
+ * Tests for the Camel Rest Server examples
+ */
+class Drools6CamelServiceExamplesTest extends Drools6IntegrationTests {
+
+ @Test
+ def testDroolsCamelServerExample = testWithFeature("examples-drools-camel-cxf-server") {
+ expect {
+ logging.containsMessage(line => line.contains("<execution-results><result identifier=\"customer\">"))
+ }
+ }
+}