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 2017/02/08 20:27:52 UTC
[13/25] servicemix-features git commit: Old modules removed
http://git-wip-us.apache.org/repos/asf/servicemix-features/blob/d358d2ea/examples/activemq/activemq-camel-blueprint/README.txt
----------------------------------------------------------------------
diff --git a/examples/activemq/activemq-camel-blueprint/README.txt b/examples/activemq/activemq-camel-blueprint/README.txt
deleted file mode 100644
index b11f0ae..0000000
--- a/examples/activemq/activemq-camel-blueprint/README.txt
+++ /dev/null
@@ -1,247 +0,0 @@
-/*
- * 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.
- */
-
-ActiveMQ & Camel in Blueprint Example
-=====================================
-
-Purpose
--------
-Deploys Camel EIP routes as an OSGi bundle using Blueprint. These routes
-make use of an ActiveMQ queue hosted on the local broker deployed in ServiceMix.
-
-Configuration makes use of the OSGi Configuration Admin service and
-Blueprint property placeholders, and the example demonstrates how to
-deploy the properties file from the ServiceMix console.
-
-
-Explanation
------------
-The Camel routes are defined in a Blueprint XML file, blueprint.xml, which can be
-found in the src/main/resources/OSGI-INF/blueprint directory of this example.
-
-The first route is defined in the first <route> element and can be explained as follows:
-
-1. A timer endpoint generates a heartbeat event every 2000ms.
-
-2. A callout is made to a transformer bean that transforms each
- heartbeat message to the current date and time.
-
-3. The message is sent to the LOG.ME queue on the ActiveMQ broker.
-
-and the second route can be explained as follows:
-
-1. The message is consumed from the LOG.ME queue on the ActiveMQ broker.
-
-2. A log endpoint sends the transformed message to the
- Jakarta commons logger.
-
-The blueprint.xml file also contains the following elements:
-
-- A <bean> and <reference> element that setup the ActiveMQ component to use the
- ConnectionFactory from the local ActiveMQ broker deployed in ServiceMix.
-
-- A <bean> element that instantiates the transformer bean using standard
- Blueprint configuration syntax and specifies a prefix value using a
- property placeholder.
-
-- An <cm:property-placeholder> element which allows you to specify placeholder
- values using the OSGi Configuration Admin service. In this case, the
- property is also given the default value of "MyTransform".
-
-The routes and configuration are deployed in an OSGi bundle.
-
-
-Prerequisites for Running the Example
--------------------------------------
-1. You must have the following installed on your machine:
-
- - JDK 1.6 or higher
-
- - Maven 2.2.1 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
--------------------
-You can run the example in two ways:
-
-- A. Using a Prebuilt Deployment Bundle: Quick and Easy
- This option is useful if you want to see the example up and
- running quickly.
-
-- B. Building the Example Bundle Yourself
- This option is useful if you want to change the example in any way.
- It tells you how to build and deploy the example. This option might
- be slower than option A because, if you do not already have the
- required bundles in your local Maven repository, Maven will have to
- download the bundles it needs.
-
-
-A. Using a Prebuilt Deployment Bundle: Quick and Easy
------------------------------------------------------
-To install and run a prebuilt version of this example, enter the
-following command in the ServiceMix console:
-
- features:install examples-activemq-camel-blueprint
-
-This command makes use of the ServiceMix features facility. For more
-information about the features facility, see the README.txt file in the
-examples parent directory.
-
-Once the example is running, periodic events are routed to the transform
-method of the MyTransform class and you should see output similar to the
-following being logged to your console screen:
-
->>>> ActiveMQ-Blueprint-Example set body: Wed Nov 30 15:37:36 NST 2011
->>>> ActiveMQ-Blueprint-Example set body: Wed Nov 30 15:37:38 NST 2011
->>>> ActiveMQ-Blueprint-Example set body: Wed Nov 30 15:37:40 NST 2011
-
-Updating and Redeploying the Properties File from the Console
--------------------------------------------------------------
-You can update and redeploy the properties file that is used by the
-properties placeholder in the blueprint.xml from console as follows:
-
-1. Edit the org.apache.servicemix.examples.cfg file, located in the
- same folder as this README, by changing the value of the "prefix"
- key to whatever you want (for example, YourTransform).
-
-2. Copy the updated configuration file to your <servicemix_home>/etc
- directory. You can do this from the ServiceMix console by typing:
-
- copy $YOUR_SERVICEMIX_HOME/examples/activemq/activemq-camel-blueprint/org.apache.servicemix.examples.cfg
- $YOUR_SERVICEMIX_HOME/etc
-
- On Windows you need to replace / in the path with \\.
-
- Note, the text you are typing might intermingle with the output
- being logged. This is nothing to worry about.
-
-3. Restart the example bundle:
-
- (i) First you must know the bundle ID that ServiceMix has assigned
- to it. To get the bundle ID, enter the following command in the
- ServiceMix console:
-
- osgi:list
-
- At the end of the listing, you should see an entry similar to
- the following:
-
- [158] [Active ] [Started ] [ 60] Apache ServiceMix Example :: ActiveMQ Camel Blueprint (4.4.0)
-
- In this case, the bundle ID is 158.
-
- (ii) Enter the following command in the ServiceMix console to
- restart the bundle:
-
- osgi:restart <bundle_id>
-
- The prefix of the output should change, and the output should look
- similar to the following:
-
- >>>> YourTransform set body: Wed Nov 30 15:37:36 NST 2011
- >>>> YourTransform set body: Wed Nov 30 15:37:38 NST 2011
- >>>> YourTransform set body: Wed Nov 30 15:37:40 NST 2011
-
-For information on how to stop and/or uninstall the example, see
-"Stopping and Uninstalling the Example" below.
-
-
-B. Building the Example Bundle Yourself
----------------------------------------
-To install and run the example where you build the example bundle
-yourself, complete the following steps:
-
-1. If you have already run the example using the prebuilt version as
- described above, you must first uninstall the examples-camel-osgi
- feature by entering the following command in the ServiceMix console:
-
- features:uninstall examples-activemq-camel-blueprint
-
-2. Build the example by opening a command prompt, changing directory to
- examples/activemq/activemq-camel-blueprint (this example) and entering the following Maven
- command:
-
- mvn 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:
-
- features:install examples-activemq-camel-blueprint
-
- It makes use of the ServiceMix features facility. For more information
- about the features facility, see the README.txt file in the examples
- parent directory.
-
-Once the example is running, periodic events are routed to the
-transform method of the MyTransform class and you should see output
-similar to the following being logged to your console screen:
-
->>>> ActiveMQ-Blueprint-Example set body: Wed Nov 30 15:37:36 NST 2011
->>>> ActiveMQ-Blueprint-Example set body: Wed Nov 30 15:37:38 NST 2011
->>>> ActiveMQ-Blueprint-Example set body: Wed Nov 30 15:37:40 NST 2011
-
-Now, if you have not already done so, try updating and redeploying,
-from the console, the properties file that is used by the properties
-placeholder in the blueprint.xml file. For details on how to do this, see
-the "Updating and Redeploying the Properties File from the Console"
-section above.
-
-
-Stopping and Uninstalling the Example
--------------------------------------
-To stop the example, enter the following command in the ServiceMix
-console:
-
- osgi:stop <bundle_id>
-
-For information on how to find the bundle_id assigned to the example,
-see step 3 in the "Updating and Redeploying the Properties File
-from the Console" section above.
-
-To uninstall the example, enter one of the following commands in
-the ServiceMix console:
-
- features:uninstall examples-activemq-camel-blueprint
-
-or
-
- osgi:uninstall <bundle_id>
-
-
-Viewing the Log Entries
------------------------
-You can view the entries in the log file in the data/log
-directory of your ServiceMix installation, or by typing
-the following command in the ServiceMix console:
-
- log:display
http://git-wip-us.apache.org/repos/asf/servicemix-features/blob/d358d2ea/examples/activemq/activemq-camel-blueprint/org.apache.servicemix.examples.cfg
----------------------------------------------------------------------
diff --git a/examples/activemq/activemq-camel-blueprint/org.apache.servicemix.examples.cfg b/examples/activemq/activemq-camel-blueprint/org.apache.servicemix.examples.cfg
deleted file mode 100644
index 16efba6..0000000
--- a/examples/activemq/activemq-camel-blueprint/org.apache.servicemix.examples.cfg
+++ /dev/null
@@ -1,22 +0,0 @@
-#
-# 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.
-#
-#
-
-
-prefix=YourTransform
http://git-wip-us.apache.org/repos/asf/servicemix-features/blob/d358d2ea/examples/activemq/activemq-camel-blueprint/pom.xml
----------------------------------------------------------------------
diff --git a/examples/activemq/activemq-camel-blueprint/pom.xml b/examples/activemq/activemq-camel-blueprint/pom.xml
deleted file mode 100644
index 3f6e90f..0000000
--- a/examples/activemq/activemq-camel-blueprint/pom.xml
+++ /dev/null
@@ -1,51 +0,0 @@
-<?xml version="1.0" encoding="UTF-8"?>
-<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/maven-v4_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>activemq-examples</artifactId>
- <version>4.6.0-SNAPSHOT</version>
- </parent>
-
- <artifactId>activemq-camel-blueprint</artifactId>
- <packaging>bundle</packaging>
- <name>Apache ServiceMix :: Features :: Examples :: ActiveMQ Camel Blueprint</name>
- <description>Camel Example using blueprint for configuration and ActiveMQ for JMS messaging</description>
-
- <build>
- <plugins>
- <plugin>
- <groupId>org.apache.felix</groupId>
- <artifactId>maven-bundle-plugin</artifactId>
- <configuration>
- <instructions>
- <Bundle-SymbolicName>${project.artifactId}</Bundle-SymbolicName>
- <Bundle-Description>${project.description}</Bundle-Description>
- <Import-Package>*,org.apache.camel.osgi</Import-Package>
- <Private-Package>org.apache.servicemix.examples.activemq</Private-Package>
- </instructions>
- </configuration>
- </plugin>
- </plugins>
- </build>
-
-</project>
http://git-wip-us.apache.org/repos/asf/servicemix-features/blob/d358d2ea/examples/activemq/activemq-camel-blueprint/src/main/java/org/apache/servicemix/examples/activemq/MyTransform.java
----------------------------------------------------------------------
diff --git a/examples/activemq/activemq-camel-blueprint/src/main/java/org/apache/servicemix/examples/activemq/MyTransform.java b/examples/activemq/activemq-camel-blueprint/src/main/java/org/apache/servicemix/examples/activemq/MyTransform.java
deleted file mode 100644
index b9f0219..0000000
--- a/examples/activemq/activemq-camel-blueprint/src/main/java/org/apache/servicemix/examples/activemq/MyTransform.java
+++ /dev/null
@@ -1,52 +0,0 @@
-/**
- * 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.activemq;
-
-import java.util.Date;
-import java.util.logging.Logger;
-
-public class MyTransform {
-
- private static final transient Logger logger = Logger.getLogger(MyTransform.class.getName());
- private boolean verbose = true;
- private String prefix = "MyTransform";
-
- public Object transform(Object body) {
- String answer = prefix + " set body: " + new Date();
- if (verbose) {
- System.out.println(">>>> " + answer);
- }
- logger.info(">>>> " + answer);
- return answer;
- }
-
- public boolean isVerbose() {
- return verbose;
- }
-
- public void setVerbose(boolean verbose) {
- this.verbose = verbose;
- }
-
- public String getPrefix() {
- return prefix;
- }
-
- public void setPrefix(String prefix) {
- this.prefix = prefix;
- }
-}
http://git-wip-us.apache.org/repos/asf/servicemix-features/blob/d358d2ea/examples/activemq/activemq-camel-blueprint/src/main/resources/OSGI-INF/blueprint/blueprint.xml
----------------------------------------------------------------------
diff --git a/examples/activemq/activemq-camel-blueprint/src/main/resources/OSGI-INF/blueprint/blueprint.xml b/examples/activemq/activemq-camel-blueprint/src/main/resources/OSGI-INF/blueprint/blueprint.xml
deleted file mode 100644
index ce57943..0000000
--- a/examples/activemq/activemq-camel-blueprint/src/main/resources/OSGI-INF/blueprint/blueprint.xml
+++ /dev/null
@@ -1,54 +0,0 @@
-<?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:cm="http://aries.apache.org/blueprint/xmlns/blueprint-cm/v1.0.0"
- xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
- xsi:schemaLocation="http://www.osgi.org/xmlns/blueprint/v1.0.0 http://www.osgi.org/xmlns/blueprint/v1.0.0/blueprint.xsd">
-
- <camelContext xmlns="http://camel.apache.org/schema/blueprint">
- <route>
- <from uri="timer://myTimer?fixedRate=true&period=2000" />
- <bean ref="myTransform" method="transform"/>
- <to uri="activemq:queue:LOG.ME" />
- </route>
- <route>
- <from uri="activemq:queue:LOG.ME" />
- <to uri="log:ExampleActiveMQRouterBlueprint" />
- </route>
- </camelContext>
-
- <!-- use CF from ActiveMQ blueprint service running in container -->
- <reference id="connectionFactory" interface="javax.jms.ConnectionFactory" />
- <bean id="activemq" class="org.apache.activemq.camel.component.ActiveMQComponent">
- <property name="connectionFactory" ref="connectionFactory" />
- </bean>
-
- <cm:property-placeholder persistent-id="org.apache.servicemix.examples">
- <cm:default-properties>
- <cm:property name="prefix" value="ActiveMQ-Blueprint-Example"/>
- </cm:default-properties>
- </cm:property-placeholder>
-
- <bean id="myTransform" class="org.apache.servicemix.examples.activemq.MyTransform">
- <property name="prefix" value="${prefix}" />
- </bean>
-
-</blueprint>
http://git-wip-us.apache.org/repos/asf/servicemix-features/blob/d358d2ea/examples/activemq/pom.xml
----------------------------------------------------------------------
diff --git a/examples/activemq/pom.xml b/examples/activemq/pom.xml
deleted file mode 100644
index 66c8ff9..0000000
--- a/examples/activemq/pom.xml
+++ /dev/null
@@ -1,39 +0,0 @@
-<?xml version="1.0" encoding="UTF-8"?>
-<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>examples</artifactId>
- <version>4.6.0-SNAPSHOT</version>
- </parent>
-
- <groupId>org.apache.servicemix.examples</groupId>
- <artifactId>activemq-examples</artifactId>
- <packaging>pom</packaging>
- <name>Apache ServiceMix :: Features :: Examples :: ActiveMQ</name>
-
- <modules>
- <module>activemq-camel-blueprint</module>
- </modules>
-
-</project>
http://git-wip-us.apache.org/repos/asf/servicemix-features/blob/d358d2ea/examples/activiti/activiti-camel/README.txt
----------------------------------------------------------------------
diff --git a/examples/activiti/activiti-camel/README.txt b/examples/activiti/activiti-camel/README.txt
deleted file mode 100644
index 2768742..0000000
--- a/examples/activiti/activiti-camel/README.txt
+++ /dev/null
@@ -1,146 +0,0 @@
-/*
- * 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.
- */
-
-Activiti and Camel Example
-==========================
-
-Purpose
--------
-This example will show you how to use Activiti inside Apache ServiceMix and how
-interact with your Activiti processes from within you Camel routes.
-
-In our example, we define a simple order process, that process the incoming orders
-and subsequently waits for its delivery. Once the delivery notification has been
-received, another bit of processing occurs before the business process ends.
-
-We use Camel routes to start new process instances and notify running processes
-about deliveries. We also use Camel routes to implement the order and delivery
-processing itself.
-
-
-Explanation
------------
-In the Blueprint XML file (activiti-camel.xml), we are:
-1. setting up our Camel context with our Camel routes
-2. setting up the ActivitiComponent that will allow us to interact between our business process and our Camel routes
-3. registering a ContextProvider instance to make your CamelContext available through the ${camel} expression in your
- business process definitions files
-
-The OrderProcess.bpmn20.xml business process definition defines the BPMN definition for our process. This process is
-automatically deployed as soon as bundle is started:
-
- start --> processOrder --> waitForDelivery --> processDelivery --> end
-
-The ActivitRouteBuilder class defines 4 routes:
-1. The first route will process files in the var/activiti-camel/order and for every file, a new business process instance
- will be started. The Camel route will also assign a business key to the new process (the file name) and add a few
- extra variables to the process.
-2. The second route will process files in the var/activiti-camel/delivery and once again uses the file name to notify
- running processes about order deliveries.
-3. The third route will be triggered by the BPMN process when it executes its 'processOrder' service task.
-4. The fourth route will be triggered by the BPMN process when it executes its 'processDelivery' service task.
-
-
-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 Activiti.
-
- features:install activiti
-
-2. Build the example by opening a command prompt, changing directory to
- examples/activiti/activiti-camel (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:
-
- osgi:install mvn:org.apache.servicemix.examples/activiti-camel/${project.version}
-
-4. Once the bundle has been started, you will see a var/activiti-camel/order directory
- under your ServiceMix installation directory. If you create files in that directory,
- you will see output like this appearing in the log file.
-
- Processing order 1508 created on 2012-06-26 11:50:19
- original message: <message/>
- Process to handle incoming order file has been started (process instance id 14808)
-
- At that point, you have a running process instance for order 1508 that is waiting for delivery.
-
-5. To notify the process about the delivery, you have to create a file with the same name
- in the var/activiti-camel/delivery directory. For example, to signal the delivery of order 1508,
- create a file named var/activiti-camel/delivery/1508. As soon as the Camel route picks up the
- file, you will see more output from the business process:
-
- Notifying process about delivery for order 1508
- Processing delivery for order 1508 created on 2012-06-26 11:50:19
- original message: <message/>
-
-
-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
-
- [ 317] [Active ] [Created ] [ ] [ 80] Apache ServiceMix :: Examples :: Activiti :: Activiti Camel (${project.version})
-
-In the above case, the bundle id would be 317
-
-
-To stop the example, enter the following command in the ServiceMix
-console:
-
- osgi:stop <bundle_id>
-
-
-To uninstall the example, enter one of the following commands in
-the ServiceMix console:
-
- osgi:uninstall <bundle_id>
\ No newline at end of file
http://git-wip-us.apache.org/repos/asf/servicemix-features/blob/d358d2ea/examples/activiti/activiti-camel/pom.xml
----------------------------------------------------------------------
diff --git a/examples/activiti/activiti-camel/pom.xml b/examples/activiti/activiti-camel/pom.xml
deleted file mode 100644
index efe2132..0000000
--- a/examples/activiti/activiti-camel/pom.xml
+++ /dev/null
@@ -1,61 +0,0 @@
-<?xml version="1.0" encoding="UTF-8"?>
-<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>
- <artifactId>activiti-examples</artifactId>
- <groupId>org.apache.servicemix.examples</groupId>
- <version>4.6.0-SNAPSHOT</version>
- </parent>
-
- <artifactId>activiti-camel</artifactId>
- <packaging>bundle</packaging>
- <name>Apache ServiceMix :: Examples :: Activiti :: Activiti Camel</name>
-
- <dependencies>
- <dependency>
- <groupId>org.apache.camel</groupId>
- <artifactId>camel-core</artifactId>
- </dependency>
- <dependency>
- <groupId>org.activiti</groupId>
- <artifactId>activiti-camel</artifactId>
- </dependency>
- </dependencies>
-
- <build>
- <plugins>
- <plugin>
- <groupId>org.apache.felix</groupId>
- <artifactId>maven-bundle-plugin</artifactId>
- <configuration>
- <instructions>
- <Bundle-SymbolicName>${project.artifactId}</Bundle-SymbolicName>
- <Bundle-Description>${project.description}</Bundle-Description>
- <Import-Package>*</Import-Package>
- <Private-Package>org.apache.servicemix.examples.activiti</Private-Package>
- </instructions>
- </configuration>
- </plugin>
- </plugins>
- </build>
-
-</project>
http://git-wip-us.apache.org/repos/asf/servicemix-features/blob/d358d2ea/examples/activiti/activiti-camel/src/main/java/org/apache/servicemix/examples/activiti/ActivitiRouteBuilder.java
----------------------------------------------------------------------
diff --git a/examples/activiti/activiti-camel/src/main/java/org/apache/servicemix/examples/activiti/ActivitiRouteBuilder.java b/examples/activiti/activiti-camel/src/main/java/org/apache/servicemix/examples/activiti/ActivitiRouteBuilder.java
deleted file mode 100644
index f8b8bd6..0000000
--- a/examples/activiti/activiti-camel/src/main/java/org/apache/servicemix/examples/activiti/ActivitiRouteBuilder.java
+++ /dev/null
@@ -1,95 +0,0 @@
-/**
- * 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.activiti;
-
-import org.apache.camel.Body;
-import org.apache.camel.Exchange;
-import org.apache.camel.Handler;
-import org.apache.camel.Header;
-import org.apache.camel.builder.RouteBuilder;
-import org.apache.camel.language.Simple;
-
-import java.util.HashMap;
-import java.util.Map;
-
-import static org.activiti.camel.ActivitiProducer.PROCESS_KEY_PROPERTY;
-
-/**
- * Camel routes that interact with the business process defined in the
- * OSGI-INF/activiti/OrderProcess.bpmn20.xml file
- */
-public class ActivitiRouteBuilder extends RouteBuilder {
-
- private final Helper helper = new Helper();
-
- @Override
- public void configure() throws Exception {
- /*
- * This route will start a new OrderProcess instance. Using the PROCESS_KEY_PROPERTY, we are assigning a
- * business key to our process to allow for easier correlation in later processing steps. We are also
- * sending a Map containing additional variables to add to the process instance.
- */
- from("file:var/activiti-camel/order")
- .setBody(bean(helper))
- .setProperty(PROCESS_KEY_PROPERTY, simple("file:name"))
- .to("activiti:OrderProcess")
- .log("Process to handle incoming order file has been started (process instance id ${body})");
-
- /*
- * This route will notify a running OrderProcess of an order delivery event. Here too, we are setting the
- * PROCESS_KEY_PROPERTY to correlate the delivery message with right order process instance.
- */
- from("file:var/activiti-camel/delivery")
- .log("Notifying process about delivery for order ${file:name}")
- .setProperty(PROCESS_KEY_PROPERTY, simple("file:name"))
- .to("activiti:OrderProcess:receiveDelivery");
-
- /*
- * The BPMN process can also trigger Camel routes as part of the process. In these routes, the variables that
- * you added to the process are available as Exchange properties. The next two routes will be triggered while
- * processing the order and the order delivery.
- */
- from("activiti:OrderProcess:processOrder")
- .log("Processing order ${property.orderid} created on ${property:timestamp}")
- .log(" original message: ${property.message}");
-
- from("activiti:OrderProcess:processDelivery")
- .log("Processing delivery for order ${property.orderid} created on ${property:timestamp}")
- .log(" original message: ${property.message}");
- }
-
- /*
- * A few helper methods used for routing
- */
- public static final class Helper {
-
- /*
- * This method will extract information from the Exchange (using Camel annotations) and put them in a
- * Map that will be used for setting up the process' variables.
- */
- @Handler
- public Map getProcessVariables(@Body String body,
- @Header(Exchange.FILE_NAME) String filename,
- @Simple("${date:now:yyyy-MM-dd kk:mm:ss}") String timestamp) {
- Map<String, Object> variables = new HashMap<String, Object>();
- variables.put("message", body);
- variables.put("orderid", filename);
- variables.put("timestamp", timestamp);
- return variables;
- }
- }
-}
http://git-wip-us.apache.org/repos/asf/servicemix-features/blob/d358d2ea/examples/activiti/activiti-camel/src/main/resources/OSGI-INF/activiti/OrderProcess.bpmn20.xml
----------------------------------------------------------------------
diff --git a/examples/activiti/activiti-camel/src/main/resources/OSGI-INF/activiti/OrderProcess.bpmn20.xml b/examples/activiti/activiti-camel/src/main/resources/OSGI-INF/activiti/OrderProcess.bpmn20.xml
deleted file mode 100644
index 8695f32..0000000
--- a/examples/activiti/activiti-camel/src/main/resources/OSGI-INF/activiti/OrderProcess.bpmn20.xml
+++ /dev/null
@@ -1,44 +0,0 @@
-<?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.
--->
-<definitions xmlns="http://www.omg.org/spec/BPMN/20100524/MODEL" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:activiti="http://activiti.org/bpmn" xmlns:bpmndi="http://www.omg.org/spec/BPMN/20100524/DI" xmlns:omgdc="http://www.omg.org/spec/DD/20100524/DC" xmlns:omgdi="http://www.omg.org/spec/DD/20100524/DI"
- typeLanguage="http://www.w3.org/2001/XMLSchema" expressionLanguage="http://www.w3.org/1999/XPath" targetNamespace="http://www.activiti.org/test">
-
-
- <process id="OrderProcess" isExecutable="true">
-
- <startEvent id="start"/>
-
- <sequenceFlow id="flow1" sourceRef="start" targetRef="processOrder"/>
-
- <serviceTask id="processOrder" activiti:delegateExpression="${camel}"/>
-
- <sequenceFlow id="flow2" sourceRef="processOrder" targetRef="receiveDelivery"/>
-
- <receiveTask id="receiveDelivery" name="Wait for Delivery" />
-
- <sequenceFlow id="flow3" sourceRef="receiveDelivery" targetRef="processDelivery"/>
-
- <serviceTask id="processDelivery" activiti:delegateExpression="${camel}"/>
-
- <sequenceFlow id="flow4" sourceRef="processDelivery" targetRef="end"/>
-
- <endEvent id="end"/>
-
- </process>
-
-</definitions>
\ No newline at end of file
http://git-wip-us.apache.org/repos/asf/servicemix-features/blob/d358d2ea/examples/activiti/activiti-camel/src/main/resources/OSGI-INF/blueprint/activiti-camel.xml
----------------------------------------------------------------------
diff --git a/examples/activiti/activiti-camel/src/main/resources/OSGI-INF/blueprint/activiti-camel.xml b/examples/activiti/activiti-camel/src/main/resources/OSGI-INF/blueprint/activiti-camel.xml
deleted file mode 100644
index a2e15c0..0000000
--- a/examples/activiti/activiti-camel/src/main/resources/OSGI-INF/blueprint/activiti-camel.xml
+++ /dev/null
@@ -1,48 +0,0 @@
-<?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:camel="http://camel.apache.org/schema/blueprint">
-
- <!--
- This Camel context contains the routes that interact with our BPMN process
- -->
- <camelContext id="camelContext" xmlns="http://camel.apache.org/schema/blueprint">
- <packageScan>
- <package>org.apache.servicemix.examples.activiti</package>
- </packageScan>
- </camelContext>
-
- <!--
- Obtain a reference to Activiti's RuntimeService - this reference will automatically
- be picked up by the subsequent Activiti Camel component definition
- -->
- <reference id="runtimeService" interface="org.activiti.engine.RuntimeService" />
-
- <!--
- Register a context provider to link the Camel context to the OrderProcess definition.
- Doing this will allow your BPMN process to communicate with the Camel routes using the
- ${camel} expression
- -->
- <service interface="org.activiti.camel.ContextProvider">
- <bean class="org.activiti.camel.SimpleContextProvider">
- <argument value="OrderProcess"/>
- <argument ref="camelContext"/>
- </bean>
- </service>
-
-</blueprint>
\ No newline at end of file
http://git-wip-us.apache.org/repos/asf/servicemix-features/blob/d358d2ea/examples/activiti/pom.xml
----------------------------------------------------------------------
diff --git a/examples/activiti/pom.xml b/examples/activiti/pom.xml
deleted file mode 100644
index b40c8ab..0000000
--- a/examples/activiti/pom.xml
+++ /dev/null
@@ -1,38 +0,0 @@
-<?xml version="1.0" encoding="UTF-8"?>
-<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>examples</artifactId>
- <version>4.6.0-SNAPSHOT</version>
- </parent>
-
- <groupId>org.apache.servicemix.examples</groupId>
- <artifactId>activiti-examples</artifactId>
- <packaging>pom</packaging>
- <name>Apache ServiceMix :: Examples :: Activiti</name>
-
- <modules>
- <module>activiti-camel</module>
- </modules>
-
-</project>
http://git-wip-us.apache.org/repos/asf/servicemix-features/blob/d358d2ea/examples/akka/akka-camel/README.txt
----------------------------------------------------------------------
diff --git a/examples/akka/akka-camel/README.txt b/examples/akka/akka-camel/README.txt
deleted file mode 100644
index cb09fd4..0000000
--- a/examples/akka/akka-camel/README.txt
+++ /dev/null
@@ -1,134 +0,0 @@
-/*
- * 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.
- */
-
-Akka and Camel Example
-======================
-
-Purpose
--------
-This example will show you how to use Akka inside Apache ServiceMix and how
-interact with your Akka actors from within you Camel routes.
-
-Our example contains a route that copies files with scores for countries from
-one directory to the other. It also wiretaps this information into a statistics
-actor, which will do some number-crunching to calculate some basic descriptive
-statistics about these scores. Once every 30 seconds, a summary report will be
-generated with the statistical summary per country.
-
-Explanation
------------
-In the Blueprint XML file (akka-camel.xml), we are:
-1. setting up the Akka actor system, using the <akka:actor-system/> element
-2. creating our Camel route builder bean
-3. bootstrapping our application, using the actor system and route builder we
- defined in 1. and 2.
-
-The Camel route builder defines two distinct routes:
-1. The first route will process files in var/akka-camel/input directory and
- move them to the var/akka-camel/output directory. It will also send a copy
- of the file contents to the 'direct:stats' endpoint for Akka to work with.
-2. The second route will receive messages from the 'direct:reports' endpoint
- and write those message to files in the var/akka/reports directory
-
-And finally, we have a set of actors calculating descriptive statistics and two
-additional actors to bridge between the statistics system and the Camel routes:
-1. One of these actors acts as a consumer and receives messages on the 'direct:stats'
- endpoint to send them into the statistics actor.
-2. The other actor acts as a producer and is set up to regularly (every 30 seconds)
- send a summary report to the 'direct:reports' endpoint.
-
-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 Camel Scala DSL and
- for Akka itself.
-
- features:install camel-scala
- features:install akka
-
-2. Build the example by opening a command prompt, changing directory to
- examples/akka/akka-camel (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:
-
- osgi:install mvn:org.apache.servicemix.examples/akka-camel/${project.version}
-
-4. Once the bundle has been started, you will see a var/akka-camel/input directory
- under your ServiceMix installation directory. There are some sample files available
- in this example's src/test/resources/samples directory. If you copy these files
- to the input directory mentioned before, they will be moved to var/akka-camel/output
- directory.
-
-5. After a short while, you will also see summary reports appearing in the var/akka-camel/reports
- directory, containing the score count, average and standard deviation per country. These
- calculations are being doing asynchronously by the Akka actor system.
-
-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
-
- [ 263] [Active ] [Created ] [ ] [ 60] Apache ServiceMix :: Examples :: Akka :: Akka Camel (${project.version})
-
-In the above case, the bundle id would be 263
-
-
-To stop the example, enter the following command in the ServiceMix
-console:
-
- osgi:stop <bundle_id>
-
-
-To uninstall the example, enter one of the following commands in
-the ServiceMix console:
-
- osgi:uninstall <bundle_id>
\ No newline at end of file
http://git-wip-us.apache.org/repos/asf/servicemix-features/blob/d358d2ea/examples/akka/akka-camel/pom.xml
----------------------------------------------------------------------
diff --git a/examples/akka/akka-camel/pom.xml b/examples/akka/akka-camel/pom.xml
deleted file mode 100644
index 00a95ed..0000000
--- a/examples/akka/akka-camel/pom.xml
+++ /dev/null
@@ -1,118 +0,0 @@
-<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/maven-v4_0_0.xsd">
-
- <parent>
- <artifactId>akka-examples</artifactId>
- <groupId>org.apache.servicemix.examples</groupId>
- <version>4.5.0-SNAPSHOT</version>
- </parent>
-
- <modelVersion>4.0.0</modelVersion>
- <groupId>org.apache.servicemix.examples</groupId>
- <artifactId>akka-camel</artifactId>
- <name>Apache ServiceMix :: Examples :: Akka :: Akka Camel</name>
- <packaging>bundle</packaging>
-
- <properties>
- <akka.version>2.1-SNAPSHOT</akka.version>
- <maven-scala-plugin.version>2.15.2</maven-scala-plugin.version>
- <scala.version>2.9.1</scala.version>
- </properties>
-
- <dependencies>
- <dependency>
- <groupId>org.scala-lang</groupId>
- <artifactId>scala-library</artifactId>
- <version>${scala.version}</version>
- </dependency>
- <dependency>
- <groupId>com.typesafe.akka</groupId>
- <artifactId>akka-actor</artifactId>
- <version>${akka.version}</version>
- </dependency>
- <dependency>
- <groupId>com.typesafe.akka</groupId>
- <artifactId>akka-osgi</artifactId>
- <version>2.1-SNAPSHOT</version>
- </dependency>
- <dependency>
- <groupId>com.typesafe.akka</groupId>
- <artifactId>akka-camel</artifactId>
- <version>2.1-SNAPSHOT</version>
- </dependency>
- <dependency>
- <groupId>org.osgi</groupId>
- <artifactId>org.osgi.core</artifactId>
- </dependency>
- <dependency>
- <groupId>org.apache.camel</groupId>
- <artifactId>camel-scala</artifactId>
- <version>${camel.version}</version>
- </dependency>
- <dependency>
- <groupId>org.apache.camel</groupId>
- <artifactId>camel-test</artifactId>
- <version>${camel.version}</version>
- <scope>test</scope>
- </dependency>
- <dependency>
- <groupId>org.slf4j</groupId>
- <artifactId>slf4j-log4j12</artifactId>
- </dependency>
- <dependency>
- <groupId>junit</groupId>
- <artifactId>junit</artifactId>
- <scope>test</scope>
- </dependency>
- </dependencies>
-
- <repositories>
- <repository>
- <id>akka.releases</id>
- <url>http://repo.akka.io/releases</url>
- <name>Akka Release Repository</name>
- <releases>
- <enabled>true</enabled>
- </releases>
- <snapshots>
- <enabled>false</enabled>
- </snapshots>
- </repository>
- </repositories>
-
- <build>
- <sourceDirectory>src/main/scala</sourceDirectory>
- <testSourceDirectory>src/test/scala</testSourceDirectory>
- <plugins>
- <plugin>
- <groupId>org.scala-tools</groupId>
- <artifactId>maven-scala-plugin</artifactId>
- <version>${maven-scala-plugin.version}</version>
- <executions>
- <execution>
- <goals>
- <goal>compile</goal>
- <goal>testCompile</goal>
- </goals>
- </execution>
- </executions>
- <configuration>
- <scalaVersion>${scala.version}</scalaVersion>
- </configuration>
- </plugin>
- <plugin>
- <groupId>org.apache.felix</groupId>
- <artifactId>maven-bundle-plugin</artifactId>
- <configuration>
- <instructions>
- <Bundle-SymbolicName>${project.artifactId}</Bundle-SymbolicName>
- <Bundle-Description>${project.description}</Bundle-Description>
- <Import-Package>akka.osgi.blueprint,org.osgi.framework,akka.event,*</Import-Package>
- <Export-Package>org.apache.servicemix.examples.akka</Export-Package>
- </instructions>
- </configuration>
- </plugin>
- </plugins>
- </build>
-
-</project>
http://git-wip-us.apache.org/repos/asf/servicemix-features/blob/d358d2ea/examples/akka/akka-camel/src/main/resources/OSGI-INF/blueprint/akka-camel.xml
----------------------------------------------------------------------
diff --git a/examples/akka/akka-camel/src/main/resources/OSGI-INF/blueprint/akka-camel.xml b/examples/akka/akka-camel/src/main/resources/OSGI-INF/blueprint/akka-camel.xml
deleted file mode 100644
index 1876236..0000000
--- a/examples/akka/akka-camel/src/main/resources/OSGI-INF/blueprint/akka-camel.xml
+++ /dev/null
@@ -1,43 +0,0 @@
-<?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:akka="http://akka.io/xmlns/blueprint/v1.0.0">
-
- <!--
- The <akka:actor-system/> will create and start the Akka actor system
- -->
- <akka:actor-system id="system" name="AkkaCamelExample" />
-
- <!--
- Our Camel RouteBuilder implementation
- -->
- <bean id="routes" class="org.apache.servicemix.examples.akka.RouteBuilderImpl" />
-
- <!--
- With the static factory method Application#apply(ActorSystem, RouteBuilder), we will
- bootstrap our own applications - this method will start the statistics actors and
- it will also create and start our CamelContext with our routes.
- -->
- <bean class="org.apache.servicemix.examples.akka.Application" factory-method="apply">
- <argument ref="system" />
- <argument ref="routes" />
- </bean>
-
-</blueprint>
http://git-wip-us.apache.org/repos/asf/servicemix-features/blob/d358d2ea/examples/akka/akka-camel/src/main/resources/application.conf
----------------------------------------------------------------------
diff --git a/examples/akka/akka-camel/src/main/resources/application.conf b/examples/akka/akka-camel/src/main/resources/application.conf
deleted file mode 100644
index e8ae9f0..0000000
--- a/examples/akka/akka-camel/src/main/resources/application.conf
+++ /dev/null
@@ -1,5 +0,0 @@
-akka.actor.deployment {
- # there's no extra configuration here at the moment, but you could
- # configure routers, log levels, ... or whatever settings you need
- # for your own application
-}
\ No newline at end of file
http://git-wip-us.apache.org/repos/asf/servicemix-features/blob/d358d2ea/examples/akka/akka-camel/src/main/scala/org/apache/servicemix/examples/akka/Application.scala
----------------------------------------------------------------------
diff --git a/examples/akka/akka-camel/src/main/scala/org/apache/servicemix/examples/akka/Application.scala b/examples/akka/akka-camel/src/main/scala/org/apache/servicemix/examples/akka/Application.scala
deleted file mode 100644
index 8637f65..0000000
--- a/examples/akka/akka-camel/src/main/scala/org/apache/servicemix/examples/akka/Application.scala
+++ /dev/null
@@ -1,36 +0,0 @@
-/**
- * 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.akka
-
-import akka.actor.ActorSystem
-import org.apache.camel.scala.dsl.builder.{RouteBuilder, RouteBuilderSupport}
-
-/**
- * Application bootstrap class. This class will start the necessary actors on
- * the actor system to
- */
-object Application extends RouteBuilderSupport {
-
- def apply(system: ActorSystem, builder: RouteBuilder) = {
- val stats = Stats(system)
- val camel = CamelBridge(system, stats)
-
- camel.context.addRoutes(builder)
- stats
- }
-
-}
http://git-wip-us.apache.org/repos/asf/servicemix-features/blob/d358d2ea/examples/akka/akka-camel/src/main/scala/org/apache/servicemix/examples/akka/CamelBridge.scala
----------------------------------------------------------------------
diff --git a/examples/akka/akka-camel/src/main/scala/org/apache/servicemix/examples/akka/CamelBridge.scala b/examples/akka/akka-camel/src/main/scala/org/apache/servicemix/examples/akka/CamelBridge.scala
deleted file mode 100644
index b4d4823..0000000
--- a/examples/akka/akka-camel/src/main/scala/org/apache/servicemix/examples/akka/CamelBridge.scala
+++ /dev/null
@@ -1,80 +0,0 @@
-/**
- * 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.akka
-
-import akka.actor.{Props, Actor, ActorRef, ActorSystem}
-import akka.camel._
-import io.Source
-import org.apache.servicemix.examples.akka.Stats.{Input, Report}
-import akka.util.duration._
-
-/**
- * Sets up the actors that bridge between the Camel routes and the
- * Akka actors.
- */
-object CamelBridge {
-
- val STATS_ENDPOINT = "direct:stats"
- val REPORTS_ENDPOINT = "direct:reports"
-
- def apply(system: ActorSystem, stats: ActorRef) = {
- val camel = CamelExtension(system)
- system.actorOf(Props(new CamelConsumer(stats)), "camel.consumer")
-
- val producer = system.actorOf(Props[CamelProducer])
- system.scheduler.schedule(5 seconds, 30 seconds) {
- stats.tell(Report(), producer)
- }
-
- camel
- }
-
-}
-
-/**
- * This akka-camel consumer endpoint will receive messages from the endpointUri and
- * sends the data for each line in the String body that corresponds to <key>,<integer>
- * to the stats actor
- *
- * @param stats the stats engine entry actor
- */
-class CamelConsumer(val stats: ActorRef) extends Actor with Consumer {
-
- def endpointUri = "direct:stats"
-
- def receive = {
- case CamelMessage(body: String, _) => Source.fromString(body).getLines().foreach(line =>
- line.split(",") match {
- case Array(key, value) => try {
- stats ! Input(key, value.toInt)
- } catch {
- case e: NumberFormatException => //second element is not a number, skipping stats for it
- }
- }
- )
- }
-}
-
-/**
- * This is an akka-camel producer endpoint. Message being received by this endpoint will be forwarded
- * to the endpointUri defined.
- */
-class CamelProducer extends Actor with Producer with Oneway {
-
- def endpointUri = CamelBridge.REPORTS_ENDPOINT
-
-}
http://git-wip-us.apache.org/repos/asf/servicemix-features/blob/d358d2ea/examples/akka/akka-camel/src/main/scala/org/apache/servicemix/examples/akka/RouteBuilder.scala
----------------------------------------------------------------------
diff --git a/examples/akka/akka-camel/src/main/scala/org/apache/servicemix/examples/akka/RouteBuilder.scala b/examples/akka/akka-camel/src/main/scala/org/apache/servicemix/examples/akka/RouteBuilder.scala
deleted file mode 100644
index 34c20da..0000000
--- a/examples/akka/akka-camel/src/main/scala/org/apache/servicemix/examples/akka/RouteBuilder.scala
+++ /dev/null
@@ -1,54 +0,0 @@
-/**
- * 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.akka
-
-import org.apache.camel.scala.dsl.builder.RouteBuilder
-import org.apache.camel.Exchange
-import CamelBridge.{REPORTS_ENDPOINT, STATS_ENDPOINT}
-
-/**
- * Abstract RouteBuilder implementation with the basic route definitions,
- * but with placeholders for the endpoints to be used to allow for testing.
- */
-abstract class AbstractRouteBuilder extends RouteBuilder {
-
- def start: String
- def end: String
- def reports: String
-
- start ==> {
- wireTap(STATS_ENDPOINT, exchange => exchange.getIn.getBody(classOf[String]))
- to(end)
- }
-
- REPORTS_ENDPOINT ==> {
- setHeader(Exchange.FILE_NAME, simple("summary-${date:now:yyyyMMdd-HHmmss}.txt"))
- to(reports)
- }
-}
-
-/**
- * Runtime endpoint definitions for our route builder
- */
-class RouteBuilderImpl extends AbstractRouteBuilder {
-
- def start = "file:var/akka-camel/input"
- def end = "file:var/akka-camel/output"
-
- def reports = "file:var/akka-camel/reports"
-
-}
http://git-wip-us.apache.org/repos/asf/servicemix-features/blob/d358d2ea/examples/akka/akka-camel/src/main/scala/org/apache/servicemix/examples/akka/Stats.scala
----------------------------------------------------------------------
diff --git a/examples/akka/akka-camel/src/main/scala/org/apache/servicemix/examples/akka/Stats.scala b/examples/akka/akka-camel/src/main/scala/org/apache/servicemix/examples/akka/Stats.scala
deleted file mode 100644
index e529749..0000000
--- a/examples/akka/akka-camel/src/main/scala/org/apache/servicemix/examples/akka/Stats.scala
+++ /dev/null
@@ -1,134 +0,0 @@
-/**
- * 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.akka
-
-import akka.actor.{ActorRef, Actor, Props, ActorSystem}
-import akka.pattern._
-import akka.util.Timeout
-import akka.util.duration._
-import collection.mutable.Map
-import collection.SortedSet
-import org.apache.servicemix.examples.akka.Stats.Metric
-import java.util.concurrent.atomic.AtomicBoolean
-
-
-/**
- * A statistics engine that generates basic descriptive statistics (count, average and standard deviation) for a
- * stream of key,value pairs. Use Stats(<ActorSystem>) to start the engine and return an actor that you can interact
- * with using these two messages:
- * - Input(key, value) to submit another value for calculation
- * - Report() to request an overall report for all scores
- */
-object Stats {
-
- case class Report()
- case class Input(val key: String, val value: Int)
- case class Metric[T](val metric: String, val key: String, val result: T)
-
- def apply(system: ActorSystem) : ActorRef = system.actorOf(Props[Stats], name = "stats")
-
-}
-
-class Stats extends Actor {
-
- import Stats._
-
- val average = context.actorOf(Props[Average], "average")
- val stddev = context.actorOf(Props(new StdDev(average)), "stddev")
- val batcher = context.actorOf(Props(new Batcher(Seq(average, stddev))), "batcher")
-
- val metrics = Map.empty[String, Map[String, Any]].withDefaultValue(Map.empty[String, Any])
- val changes = new AtomicBoolean(false)
-
- def receive = {
- case Input(key, value) => batcher ! (key, value);
- case Metric(metric, key, result) => {
- metrics(key) = metrics(key) + (metric -> result)
- changes.set(true)
- }
- case Report() => {
- if (changes.getAndSet(false)) {
- val results = SortedSet(metrics.keys.toArray:_*).map { key =>
- val results = metrics(key)
- "%s,%d,%.4f,%.4f".format(key, results.getOrElse("count", 0),
- results.getOrElse("avg", Double.NaN),
- results.getOrElse("stddev", Double.NaN))
- }
- sender ! ("key,count,average,stddev" +: results.toSeq).mkString(sys.props("line.separator"))
- }
- }
- }
-
-}
-
-class Batcher(val stats: Seq[ActorRef]) extends Actor {
-
- val batches = Map.empty[String, Seq[Int]].withDefaultValue(Seq())
-
- def receive = {
- case (key: String, value: Int) => {
- val batch = value +: batches(key)
- batches(key) = batch
- for (stat <- stats) stat.tell((key, batch), sender)
- sender ! Metric("count", key, batch.size)
- }
- }
-
-}
-
-class Average extends Actor {
-
- def receive = {
- case (key: String, items: Seq[Int]) => sender ! Metric("avg", key, avg(items))
- case items: Seq[Int] => sender ! avg(items)
- }
-
-
- def avg(items: scala.Seq[Int]): Double = {
- items.foldLeft(0)(_ + _).toDouble / items.size
- }
-}
-
-class StdDev(val average: ActorRef) extends Actor {
-
- val sum_of_squares = context.actorOf(Props[SumOfSquares], "sum_of_squares")
-
- implicit val timeout = Timeout(1 seconds)
-
- def receive = {
- case (key: String, items: Seq[Int]) if items.size > 1 =>
- val original = sender
- ask(average, items).onSuccess {
- case avg : Double => {
- ask(sum_of_squares, (items, avg)).onSuccess {
- case ss : Double => {
- original ! Metric("stddev", key, math.sqrt(ss / items.size - 1))
- }
- }
- }
- }
- }
-}
-
-class SumOfSquares extends Actor {
-
- def receive = {
- case (items: Seq[Int], avg: Double) =>
- sender ! items.map(item => math.pow(item.toDouble - avg, 2)).foldLeft(0d)(_ + _)
- }
-
-}
\ No newline at end of file
http://git-wip-us.apache.org/repos/asf/servicemix-features/blob/d358d2ea/examples/akka/akka-camel/src/test/resources/generate_test_data.rb
----------------------------------------------------------------------
diff --git a/examples/akka/akka-camel/src/test/resources/generate_test_data.rb b/examples/akka/akka-camel/src/test/resources/generate_test_data.rb
deleted file mode 100755
index 365b450..0000000
--- a/examples/akka/akka-camel/src/test/resources/generate_test_data.rb
+++ /dev/null
@@ -1,25 +0,0 @@
-#!/usr/bin/ruby
-
-# 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.
-
-countries = ['AUS', 'BEL', 'CAN', 'CHN', 'FRA', 'GBR', 'GER', 'GRC', 'GRL',
- 'IRL', 'NLD', 'NOR', 'SJM', 'SWE', 'TTO', 'TZA', 'USA', 'ZMB']
-
-200.times {
- country = countries[rand(countries.length)]
- score = 1 + rand(1000)
- puts "#{country},#{score}"
-}
http://git-wip-us.apache.org/repos/asf/servicemix-features/blob/d358d2ea/examples/akka/akka-camel/src/test/resources/log4j.properties
----------------------------------------------------------------------
diff --git a/examples/akka/akka-camel/src/test/resources/log4j.properties b/examples/akka/akka-camel/src/test/resources/log4j.properties
deleted file mode 100644
index 1775b18..0000000
--- a/examples/akka/akka-camel/src/test/resources/log4j.properties
+++ /dev/null
@@ -1,33 +0,0 @@
-#
-# 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.
-#
-
-#
-# The logging properties used during tests..
-#
-log4j.rootLogger=DEBUG, out
-
-# CONSOLE appender not used by default
-log4j.appender.stdout=org.apache.log4j.ConsoleAppender
-log4j.appender.stdout.layout=org.apache.log4j.PatternLayout
-log4j.appender.stdout.layout.ConversionPattern=%d [%-15.15t] %-5p %-30.30c{1} - %m%n
-
-# File appender
-log4j.appender.out=org.apache.log4j.FileAppender
-log4j.appender.out.layout=org.apache.log4j.PatternLayout
-log4j.appender.out.layout.ConversionPattern=%d [%-15.15t] %-5p %-30.30c{1} - %m%n
-log4j.appender.out.file=target/akka-camel.log
-log4j.appender.out.append=true
http://git-wip-us.apache.org/repos/asf/servicemix-features/blob/d358d2ea/examples/akka/akka-camel/src/test/resources/samples/file1.csv
----------------------------------------------------------------------
diff --git a/examples/akka/akka-camel/src/test/resources/samples/file1.csv b/examples/akka/akka-camel/src/test/resources/samples/file1.csv
deleted file mode 100644
index 4fd5d57..0000000
--- a/examples/akka/akka-camel/src/test/resources/samples/file1.csv
+++ /dev/null
@@ -1,200 +0,0 @@
-BEL,911
-TT0,934
-BEL,496
-GRL,228
-GRL,515
-TT0,664
-TT0,578
-GBR,488
-AUS,686
-GRC,943
-TT0,980
-GRL,458
-CHN,735
-SWE,939
-USA,984
-CHN,671
-CAN,435
-ZMB,693
-GBR,77
-NLD,279
-AUS,232
-USA,857
-GBR,161
-GBR,950
-ZMB,560
-IRL,682
-TZA,949
-IRL,100
-CHN,610
-BEL,274
-GER,64
-USA,938
-FRA,288
-IRL,231
-USA,292
-IRL,343
-SJM,55
-GRC,31
-TT0,69
-GER,472
-CAN,312
-CHN,789
-GER,498
-USA,339
-FRA,830
-GBR,101
-AUS,276
-CAN,242
-FRA,321
-CHN,772
-USA,309
-CAN,302
-GBR,82
-GBR,349
-USA,83
-CHN,965
-IRL,961
-GRL,523
-SWE,232
-GRL,706
-AUS,581
-IRL,942
-NOR,299
-CHN,458
-GBR,86
-ZMB,123
-ZMB,101
-GBR,654
-IRL,229
-TT0,172
-GER,841
-SWE,892
-CAN,668
-TT0,213
-CAN,42
-FRA,710
-USA,270
-GER,59
-CAN,680
-TZA,313
-ZMB,581
-SJM,143
-FRA,661
-NOR,152
-SWE,101
-TZA,595
-GRL,390
-AUS,788
-GBR,27
-NLD,968
-TT0,711
-SWE,731
-CAN,758
-BEL,727
-TZA,94
-SJM,743
-SWE,254
-BEL,256
-IRL,912
-NLD,386
-CHN,802
-CAN,310
-BEL,725
-CAN,231
-GER,377
-GRC,379
-GBR,677
-IRL,178
-NOR,629
-TZA,505
-SWE,580
-USA,617
-NOR,604
-AUS,994
-NLD,124
-TT0,908
-BEL,432
-NOR,660
-SJM,446
-GRL,249
-FRA,167
-CHN,261
-GRL,644
-BEL,534
-GBR,622
-FRA,144
-NOR,677
-NOR,916
-NOR,724
-ZMB,807
-CAN,282
-TT0,227
-GRL,178
-NLD,612
-IRL,108
-CHN,664
-CAN,530
-TT0,344
-USA,756
-USA,502
-IRL,472
-GRC,651
-GRC,589
-USA,648
-IRL,326
-IRL,493
-AUS,941
-CAN,55
-NOR,415
-NOR,97
-TZA,69
-CHN,124
-AUS,881
-GER,239
-CAN,380
-CHN,416
-NOR,739
-NOR,921
-ZMB,917
-BEL,504
-TZA,280
-BEL,394
-GRL,233
-SWE,105
-GRL,823
-SWE,774
-GBR,410
-IRL,970
-GER,550
-IRL,857
-SWE,49
-IRL,406
-BEL,62
-ZMB,373
-FRA,524
-SWE,919
-GRC,462
-GBR,71
-USA,365
-TT0,508
-USA,291
-GER,227
-TT0,869
-CHN,511
-ZMB,651
-TZA,318
-USA,854
-IRL,387
-GRC,249
-SJM,52
-AUS,784
-GER,668
-SWE,632
-AUS,572
-GBR,533
-NOR,625
-BEL,643
-AUS,673
-SJM,958
-USA,215
http://git-wip-us.apache.org/repos/asf/servicemix-features/blob/d358d2ea/examples/akka/akka-camel/src/test/resources/samples/file2.csv
----------------------------------------------------------------------
diff --git a/examples/akka/akka-camel/src/test/resources/samples/file2.csv b/examples/akka/akka-camel/src/test/resources/samples/file2.csv
deleted file mode 100644
index 493988c..0000000
--- a/examples/akka/akka-camel/src/test/resources/samples/file2.csv
+++ /dev/null
@@ -1,200 +0,0 @@
-GRL,473
-TT0,491
-IRL,981
-USA,594
-BEL,339
-TT0,504
-NLD,421
-BEL,85
-GRC,410
-IRL,394
-BEL,783
-SWE,551
-TT0,547
-IRL,923
-ZMB,50
-GRC,971
-GRL,343
-ZMB,805
-GBR,809
-ZMB,530
-SJM,894
-IRL,926
-GBR,240
-NOR,244
-IRL,674
-AUS,333
-GRL,907
-BEL,395
-TZA,580
-BEL,186
-GBR,138
-BEL,175
-CHN,676
-TT0,478
-TT0,706
-SWE,218
-CAN,590
-TT0,793
-ZMB,756
-GRC,595
-SWE,303
-SJM,573
-GER,78
-GBR,464
-NLD,369
-TZA,751
-BEL,731
-AUS,910
-SJM,161
-BEL,362
-USA,379
-AUS,227
-SJM,430
-NLD,181
-TT0,514
-SJM,93
-GRC,418
-GRL,901
-GRC,342
-TZA,101
-GRL,825
-FRA,580
-IRL,90
-GER,250
-CAN,278
-CAN,489
-GER,388
-IRL,5
-GBR,898
-BEL,399
-ZMB,233
-CAN,872
-BEL,618
-IRL,719
-TZA,385
-SJM,260
-TZA,729
-SJM,394
-GER,973
-TZA,118
-CAN,271
-AUS,302
-GRC,45
-CAN,961
-SWE,627
-SWE,623
-GRC,569
-GRC,188
-SJM,38
-BEL,907
-AUS,592
-TT0,388
-SJM,984
-GRL,722
-BEL,216
-IRL,845
-CAN,665
-TT0,746
-GRC,319
-TZA,119
-CHN,734
-CAN,929
-CHN,626
-TZA,275
-GER,982
-CAN,957
-CHN,13
-SJM,656
-FRA,807
-TZA,134
-FRA,673
-CAN,995
-NOR,470
-TT0,72
-NOR,387
-CHN,769
-NOR,977
-GER,295
-SWE,829
-SWE,283
-FRA,60
-NOR,635
-SWE,278
-CHN,269
-USA,292
-CAN,752
-CAN,262
-TZA,276
-SWE,771
-TT0,807
-TT0,178
-NOR,682
-NLD,91
-CHN,394
-GRC,217
-BEL,427
-GRL,509
-NLD,624
-IRL,941
-CAN,213
-SJM,685
-FRA,83
-NOR,757
-GBR,712
-NLD,568
-NLD,816
-NOR,987
-CAN,995
-CAN,914
-FRA,347
-NOR,916
-TT0,156
-USA,267
-CHN,707
-NLD,57
-GRL,875
-NLD,834
-GER,673
-GER,91
-GER,911
-ZMB,207
-TT0,537
-ZMB,984
-IRL,168
-NLD,435
-GBR,658
-CHN,365
-GER,599
-GRL,94
-ZMB,440
-USA,993
-GBR,351
-GRL,64
-GER,213
-IRL,214
-USA,623
-SJM,242
-CAN,644
-SWE,399
-FRA,441
-SJM,943
-GRC,585
-FRA,398
-CHN,220
-BEL,780
-GER,564
-NOR,134
-CAN,466
-SJM,401
-SWE,378
-TT0,33
-GRL,195
-USA,95
-ZMB,958
-CHN,235
-GER,525
-GRL,325
-AUS,100
-GRC,52
-IRL,766
http://git-wip-us.apache.org/repos/asf/servicemix-features/blob/d358d2ea/examples/akka/akka-camel/src/test/resources/samples/file3.csv
----------------------------------------------------------------------
diff --git a/examples/akka/akka-camel/src/test/resources/samples/file3.csv b/examples/akka/akka-camel/src/test/resources/samples/file3.csv
deleted file mode 100644
index 9a0e30c..0000000
--- a/examples/akka/akka-camel/src/test/resources/samples/file3.csv
+++ /dev/null
@@ -1,200 +0,0 @@
-FRA,672
-USA,491
-GER,503
-SWE,730
-NLD,242
-ZMB,259
-NOR,565
-GBR,38
-AUS,333
-SWE,922
-USA,983
-IRL,953
-GRC,780
-IRL,446
-GRC,889
-USA,625
-NLD,407
-AUS,1000
-AUS,29
-TT0,715
-SWE,319
-TT0,311
-GER,359
-GER,430
-CAN,814
-CAN,306
-CHN,25
-NOR,159
-FRA,510
-AUS,244
-CAN,344
-AUS,688
-IRL,966
-NOR,988
-SWE,747
-GBR,3
-NOR,752
-IRL,474
-USA,761
-AUS,226
-GRL,877
-SWE,38
-NLD,410
-BEL,250
-SJM,430
-NLD,616
-NLD,695
-FRA,551
-ZMB,35
-CHN,247
-CAN,330
-GBR,265
-GRL,745
-GRL,918
-GBR,947
-NOR,498
-CHN,649
-BEL,456
-GBR,445
-CHN,847
-NLD,238
-CAN,648
-GRL,263
-NLD,419
-GRC,994
-NLD,879
-NOR,271
-TT0,786
-ZMB,159
-GRL,509
-BEL,614
-TZA,610
-TT0,340
-NLD,420
-NLD,166
-NOR,70
-IRL,126
-GRL,843
-GRC,694
-TT0,892
-BEL,351
-GRL,604
-GER,512
-AUS,6
-CAN,277
-GER,401
-SWE,705
-CAN,882
-IRL,817
-NOR,715
-GER,227
-SJM,582
-TZA,963
-GER,913
-CHN,679
-TZA,89
-AUS,587
-TZA,799
-SJM,729
-GBR,325
-USA,377
-FRA,937
-GRC,660
-GER,79
-CHN,302
-SWE,224
-USA,724
-SJM,872
-GRL,466
-BEL,568
-ZMB,850
-GRC,199
-GER,110
-FRA,57
-NLD,543
-CHN,761
-BEL,447
-USA,61
-AUS,175
-ZMB,18
-ZMB,260
-USA,473
-SWE,792
-GRC,722
-TT0,450
-FRA,970
-TZA,470
-SJM,428
-GRC,45
-SJM,733
-GRL,951
-FRA,140
-GRL,849
-USA,397
-ZMB,830
-GBR,942
-TT0,248
-TT0,752
-TZA,224
-CAN,424
-SJM,359
-GRC,322
-GRC,234
-NOR,243
-GBR,625
-CHN,584
-SJM,559
-NOR,887
-CAN,190
-AUS,61
-FRA,536
-USA,219
-CAN,583
-GRC,449
-NOR,236
-CAN,104
-GER,996
-AUS,252
-ZMB,931
-NLD,424
-AUS,786
-SWE,662
-GER,267
-NOR,209
-SJM,919
-TT0,49
-IRL,29
-SWE,84
-GRC,525
-NOR,417
-GRC,716
-SWE,576
-IRL,86
-GBR,525
-GER,332
-GRL,867
-FRA,510
-GBR,558
-GRL,727
-AUS,959
-TT0,248
-TZA,176
-TZA,643
-NOR,432
-FRA,4
-GRC,75
-CAN,821
-NOR,245
-ZMB,839
-GER,210
-SWE,111
-ZMB,879
-NOR,304
-BEL,889
-IRL,127
-ZMB,334
-TT0,829
-GRC,700
-NLD,681
-SWE,381
http://git-wip-us.apache.org/repos/asf/servicemix-features/blob/d358d2ea/examples/akka/akka-camel/src/test/resources/samples/file4.csv
----------------------------------------------------------------------
diff --git a/examples/akka/akka-camel/src/test/resources/samples/file4.csv b/examples/akka/akka-camel/src/test/resources/samples/file4.csv
deleted file mode 100644
index 583761d..0000000
--- a/examples/akka/akka-camel/src/test/resources/samples/file4.csv
+++ /dev/null
@@ -1,200 +0,0 @@
-USA,741
-FRA,291
-GBR,383
-AUS,250
-NLD,561
-TT0,70
-GRC,942
-CAN,107
-NLD,618
-ZMB,130
-FRA,927
-GRL,890
-CHN,510
-FRA,966
-GBR,98
-FRA,420
-GBR,573
-USA,396
-CAN,811
-GER,70
-GRL,451
-BEL,75
-TZA,332
-GRC,885
-FRA,983
-TZA,591
-GBR,661
-AUS,658
-BEL,83
-ZMB,82
-NLD,480
-SWE,249
-IRL,576
-NOR,758
-IRL,249
-GRC,714
-IRL,560
-BEL,691
-SWE,778
-SWE,437
-NLD,405
-TZA,697
-SWE,239
-GER,266
-CAN,762
-SWE,692
-IRL,68
-GER,244
-CHN,98
-GER,210
-GRL,960
-IRL,7
-TZA,870
-SWE,635
-USA,90
-NOR,588
-SJM,89
-GRL,399
-NLD,296
-SWE,365
-USA,922
-BEL,774
-GER,540
-NOR,623
-AUS,658
-AUS,980
-NLD,139
-USA,925
-TZA,941
-GER,226
-GER,957
-CAN,889
-NOR,418
-CAN,984
-GRC,885
-TT0,532
-IRL,199
-CHN,153
-IRL,111
-GRC,280
-AUS,1000
-TZA,911
-SJM,974
-FRA,470
-NOR,749
-ZMB,243
-GBR,456
-ZMB,460
-BEL,804
-SWE,567
-GRC,18
-NLD,402
-GBR,942
-ZMB,206
-CHN,977
-ZMB,391
-CHN,692
-ZMB,43
-GRL,571
-CHN,825
-NOR,195
-IRL,257
-GER,648
-AUS,302
-NOR,518
-FRA,310
-CHN,274
-IRL,868
-NLD,802
-GRC,28
-CHN,140
-GRC,949
-USA,261
-FRA,287
-GER,727
-SJM,350
-TT0,239
-TZA,791
-ZMB,78
-SWE,542
-TZA,6
-GER,337
-GBR,819
-GER,997
-USA,89
-SJM,104
-CAN,869
-SWE,637
-GBR,764
-SJM,797
-TZA,71
-ZMB,526
-AUS,111
-GER,997
-SWE,574
-BEL,751
-CAN,905
-GRL,91
-BEL,511
-IRL,338
-CHN,140
-IRL,572
-GRL,297
-GER,64
-TZA,87
-USA,107
-GER,841
-GER,396
-NLD,118
-CAN,619
-CAN,325
-NLD,805
-AUS,309
-CHN,383
-FRA,819
-IRL,89
-NOR,748
-TT0,133
-ZMB,265
-IRL,443
-NOR,677
-FRA,226
-BEL,327
-GRL,808
-SJM,442
-TZA,425
-IRL,678
-USA,218
-USA,812
-TZA,420
-TT0,803
-FRA,766
-GRL,562
-BEL,212
-CAN,163
-IRL,339
-FRA,741
-GRC,677
-FRA,609
-GER,754
-BEL,349
-SJM,186
-SJM,126
-CAN,136
-TZA,729
-GRC,636
-USA,667
-ZMB,650
-USA,686
-GRC,706
-USA,200
-IRL,472
-AUS,971
-SWE,691
-CAN,715
-CHN,399
-SJM,456
-GRC,195
-CAN,793
-USA,832
http://git-wip-us.apache.org/repos/asf/servicemix-features/blob/d358d2ea/examples/akka/akka-camel/src/test/resources/samples/file5.csv
----------------------------------------------------------------------
diff --git a/examples/akka/akka-camel/src/test/resources/samples/file5.csv b/examples/akka/akka-camel/src/test/resources/samples/file5.csv
deleted file mode 100644
index 4bbcd25..0000000
--- a/examples/akka/akka-camel/src/test/resources/samples/file5.csv
+++ /dev/null
@@ -1,200 +0,0 @@
-GRC,360
-NOR,151
-FRA,138
-GBR,559
-AUS,222
-NOR,899
-GER,733
-TZA,535
-GER,214
-TZA,154
-GRC,464
-SWE,426
-IRL,158
-AUS,417
-BEL,848
-SWE,488
-GBR,756
-SWE,677
-NLD,461
-GRL,744
-SWE,399
-BEL,745
-GBR,338
-FRA,635
-GRL,607
-GRL,21
-GER,448
-FRA,938
-ZMB,197
-SWE,391
-GRC,385
-BEL,856
-TZA,678
-ZMB,307
-NLD,132
-SJM,542
-BEL,152
-ZMB,517
-TZA,128
-NOR,354
-SWE,359
-SJM,179
-TZA,136
-NOR,829
-SWE,304
-NOR,670
-GER,634
-NLD,81
-NLD,316
-GER,952
-GER,624
-SWE,62
-IRL,633
-AUS,760
-SWE,753
-TZA,77
-CHN,201
-NLD,469
-SWE,899
-GRL,151
-CHN,108
-BEL,334
-AUS,527
-TZA,118
-ZMB,349
-AUS,868
-TT0,718
-GER,59
-TT0,119
-FRA,118
-CHN,397
-USA,75
-IRL,920
-NLD,180
-USA,535
-NLD,321
-ZMB,157
-BEL,704
-SJM,500
-NLD,233
-FRA,612
-NOR,965
-IRL,13
-CAN,305
-GER,610
-NOR,444
-GRC,865
-ZMB,533
-NLD,621
-TZA,285
-USA,528
-FRA,896
-TZA,734
-GRC,53
-BEL,790
-CAN,399
-GER,414
-TZA,458
-SJM,911
-CHN,466
-CAN,957
-TT0,833
-NOR,404
-FRA,774
-GER,339
-IRL,454
-TZA,83
-BEL,828
-AUS,714
-CHN,727
-GBR,664
-SJM,738
-GRC,58
-GRL,57
-USA,155
-BEL,452
-SWE,299
-FRA,502
-SJM,476
-USA,366
-BEL,451
-CAN,162
-SJM,806
-ZMB,401
-SWE,485
-TT0,377
-CHN,425
-USA,4
-GRC,222
-FRA,417
-BEL,224
-GBR,30
-FRA,853
-GRL,249
-GER,998
-NOR,93
-GBR,476
-IRL,77
-BEL,367
-GER,988
-IRL,244
-SJM,802
-IRL,98
-CHN,60
-SJM,445
-CAN,243
-GER,833
-CHN,823
-GER,241
-NLD,777
-NLD,99
-CHN,184
-GRL,527
-GBR,725
-GER,190
-ZMB,903
-AUS,611
-NLD,285
-SJM,959
-TZA,498
-GER,224
-BEL,243
-NOR,236
-FRA,839
-USA,915
-NOR,561
-BEL,586
-GRC,873
-TZA,254
-NLD,192
-USA,972
-CAN,655
-FRA,452
-CHN,850
-TT0,493
-TZA,540
-CAN,431
-GRL,823
-GRC,69
-GBR,107
-GBR,511
-TT0,565
-CAN,239
-TZA,103
-TZA,824
-AUS,652
-GBR,804
-NLD,330
-TZA,165
-TT0,809
-GRL,733
-ZMB,990
-TZA,371
-GBR,972
-GER,144
-GRL,418
-SWE,144
-SJM,620
-TT0,314
-GBR,963
http://git-wip-us.apache.org/repos/asf/servicemix-features/blob/d358d2ea/examples/akka/akka-camel/src/test/scala/org/apache/servicemix/examples/akka/RouteBuilderTest.scala
----------------------------------------------------------------------
diff --git a/examples/akka/akka-camel/src/test/scala/org/apache/servicemix/examples/akka/RouteBuilderTest.scala b/examples/akka/akka-camel/src/test/scala/org/apache/servicemix/examples/akka/RouteBuilderTest.scala
deleted file mode 100644
index 64380c6..0000000
--- a/examples/akka/akka-camel/src/test/scala/org/apache/servicemix/examples/akka/RouteBuilderTest.scala
+++ /dev/null
@@ -1,57 +0,0 @@
-/**
- * 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.akka
-
-import org.apache.camel.test.junit4.CamelTestSupport
-import org.apache.camel.scala.dsl.builder.RouteBuilderSupport
-import akka.actor.ActorSystem
-import org.junit.Test
-import akka.camel.CamelExtension
-
-/**
- * Test case for the {{AbstractRouteBuilder}}
- */
-class RouteBuilderTest extends CamelTestSupport with RouteBuilderSupport {
-
- val MOCK_END = "mock:end"
- val MOCK_REPORTS = "mock:reports"
-
- val system = ActorSystem("RouteBuilderTest")
-
- // let's start the actual application here
- Application(system, new AbstractRouteBuilder {
- def start = "file:src/test/resources/samples?noop=true"
- def end = MOCK_END
-
- def reports = MOCK_REPORTS
- })
-
- @Test
- def testRoute {
- // we expect our 5 files to be transferred through the route
- getMockEndpoint(MOCK_END).expectedMessageCount(5)
-
- // we expect at least on statistical report within the time required to finish the route
- getMockEndpoint(MOCK_REPORTS).expectedMinimumMessageCount(1)
-
- assertMockEndpointsSatisfied()
- }
-
- // override this to allow using the CamelTestSupport convenience methods for our akka-camel CamelContext instance
- override def createCamelContext()= CamelExtension(system).context
-
-}