camel-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From hekon...@apache.org
Subject camel git commit: [CAMEL-8808] Created Grape component.
Date Wed, 27 May 2015 20:37:49 GMT
Repository: camel
Updated Branches:
  refs/heads/master c936be321 -> 520295b22


[CAMEL-8808] Created Grape component.


Project: http://git-wip-us.apache.org/repos/asf/camel/repo
Commit: http://git-wip-us.apache.org/repos/asf/camel/commit/520295b2
Tree: http://git-wip-us.apache.org/repos/asf/camel/tree/520295b2
Diff: http://git-wip-us.apache.org/repos/asf/camel/diff/520295b2

Branch: refs/heads/master
Commit: 520295b22b03058c5b4149ad7cd5b99c4af9aef3
Parents: c936be3
Author: Henryk Konsek <hekonsek@gmail.com>
Authored: Wed May 27 22:37:39 2015 +0200
Committer: Henryk Konsek <hekonsek@gmail.com>
Committed: Wed May 27 22:37:39 2015 +0200

----------------------------------------------------------------------
 components/camel-grape/pom.xml                  | 114 +++++++++++++++++++
 .../grape/FilePatchesRepository.groovy          |  60 ++++++++++
 .../camel/component/grape/GrapeCommand.groovy   |  25 ++++
 .../camel/component/grape/GrapeComponent.groovy |  38 +++++++
 .../camel/component/grape/GrapeConstants.groovy |  23 ++++
 .../camel/component/grape/GrapeEndpoint.groovy  |  70 ++++++++++++
 .../camel/component/grape/GrapeProducer.groovy  |  68 +++++++++++
 .../component/grape/MavenCoordinates.groovy     |  50 ++++++++
 .../component/grape/PatchesRepository.groovy    |  27 +++++
 .../services/org/apache/camel/component/grape   |  17 +++
 .../component/grape/GrapeComponentTest.groovy   | 100 ++++++++++++++++
 components/pom.xml                              |   1 +
 parent/pom.xml                                  |   8 +-
 13 files changed, 598 insertions(+), 3 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/camel/blob/520295b2/components/camel-grape/pom.xml
----------------------------------------------------------------------
diff --git a/components/camel-grape/pom.xml b/components/camel-grape/pom.xml
new file mode 100644
index 0000000..9197371
--- /dev/null
+++ b/components/camel-grape/pom.xml
@@ -0,0 +1,114 @@
+<?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.
+-->
+<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">
+
+	<modelVersion>4.0.0</modelVersion>
+
+	<parent>
+		<groupId>org.apache.camel</groupId>
+		<artifactId>components</artifactId>
+		<version>2.16-SNAPSHOT</version>
+	</parent>
+
+	<artifactId>camel-grape</artifactId>
+	<name>Camel :: Grape</name>
+	<description>Camel Component for Grape</description>
+
+	<properties>
+		<groovy-eclipse-batch.version>2.3.7-01</groovy-eclipse-batch.version>
+		<groovy-eclipse-compiler.version>2.9.1-01</groovy-eclipse-compiler.version>
+		<plexus-compiler-api.version>2.4</plexus-compiler-api.version>
+	</properties>
+
+	<dependencies>
+		<dependency>
+			<groupId>commons-io</groupId>
+			<artifactId>commons-io</artifactId>
+			<version>${commons-io-version}</version>
+		</dependency>
+		<dependency>
+			<groupId>org.apache.commons</groupId>
+			<artifactId>commons-lang3</artifactId>
+			<version>${commons-lang3-version}</version>
+		</dependency>
+		<dependency>
+			<groupId>org.apache.camel</groupId>
+			<artifactId>camel-core</artifactId>
+		</dependency>
+		<dependency>
+			<groupId>org.apache.ivy</groupId>
+			<artifactId>ivy</artifactId>
+			<version>${ivy-version}</version>
+		</dependency>
+		<dependency>
+			<groupId>org.codehaus.groovy</groupId>
+			<artifactId>groovy</artifactId>
+			<version>${groovy-version}</version>
+		</dependency>
+
+		<!-- Testing -->
+		<dependency>
+			<groupId>org.apache.camel</groupId>
+			<artifactId>camel-test</artifactId>
+			<scope>test</scope>
+		</dependency>
+        <dependency>
+			<groupId>ch.qos.logback</groupId>
+			<artifactId>logback-classic</artifactId>
+			<scope>test</scope>
+			<version>${logback-version}</version>
+		</dependency>
+    </dependencies>
+
+	<build>
+		<plugins>
+			<plugin>
+				<groupId>org.apache.maven.plugins</groupId>
+				<artifactId>maven-compiler-plugin</artifactId>
+				<dependencies>
+					<dependency>
+						<groupId>org.codehaus.groovy</groupId>
+						<artifactId>groovy-eclipse-batch</artifactId>
+						<version>${groovy-eclipse-batch.version}</version>
+					</dependency>
+					<dependency>
+						<groupId>org.codehaus.groovy</groupId>
+						<artifactId>groovy-eclipse-compiler</artifactId>
+						<version>${groovy-eclipse-compiler.version}</version>
+					</dependency>
+					<dependency>
+						<groupId>org.codehaus.plexus</groupId>
+						<artifactId>plexus-compiler-api</artifactId>
+						<version>${plexus-compiler-api.version}</version>
+					</dependency>
+				</dependencies>
+				<configuration>
+					<compilerId>groovy-eclipse-compiler</compilerId>
+				</configuration>
+			</plugin>
+			<plugin>
+				<groupId>org.codehaus.groovy</groupId>
+				<artifactId>groovy-eclipse-compiler</artifactId>
+				<version>${groovy-eclipse-compiler.version}</version>
+				<extensions>true</extensions>
+			</plugin>
+		</plugins>
+	</build>
+
+</project>
\ No newline at end of file

http://git-wip-us.apache.org/repos/asf/camel/blob/520295b2/components/camel-grape/src/main/groovy/org/apache/camel/component/grape/FilePatchesRepository.groovy
----------------------------------------------------------------------
diff --git a/components/camel-grape/src/main/groovy/org/apache/camel/component/grape/FilePatchesRepository.groovy
b/components/camel-grape/src/main/groovy/org/apache/camel/component/grape/FilePatchesRepository.groovy
new file mode 100644
index 0000000..2689453
--- /dev/null
+++ b/components/camel-grape/src/main/groovy/org/apache/camel/component/grape/FilePatchesRepository.groovy
@@ -0,0 +1,60 @@
+/**
+ * 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.camel.component.grape
+
+import org.apache.commons.lang3.SystemUtils
+
+import java.nio.file.Paths
+
+import static org.apache.commons.io.FileUtils.writeStringToFile
+import static org.apache.commons.io.IOUtils.readLines
+
+class FilePatchesRepository implements PatchesRepository {
+
+    private final File repository
+
+    FilePatchesRepository() {
+        this(Paths.get(SystemUtils.userHome.absolutePath, ".camel-iot-labs", "patches").toFile())
+    }
+
+    FilePatchesRepository(File repository) {
+        if(!repository.exists()) {
+            if(repository.getParentFile() != null) {
+                repository.getParentFile().mkdirs()
+            }
+            repository.createNewFile()
+        }
+        this.repository = repository
+    }
+
+    @Override
+    void install(String coordinates) {
+        writeStringToFile(repository, coordinates + "\n", true);
+    }
+
+    @Override
+    List<String> listPatches() {
+        readLines(new FileReader(repository))
+    }
+
+    @Override
+    void clear() {
+        repository.delete()
+        repository.createNewFile()
+    }
+
+}

http://git-wip-us.apache.org/repos/asf/camel/blob/520295b2/components/camel-grape/src/main/groovy/org/apache/camel/component/grape/GrapeCommand.groovy
----------------------------------------------------------------------
diff --git a/components/camel-grape/src/main/groovy/org/apache/camel/component/grape/GrapeCommand.groovy
b/components/camel-grape/src/main/groovy/org/apache/camel/component/grape/GrapeCommand.groovy
new file mode 100644
index 0000000..901b992
--- /dev/null
+++ b/components/camel-grape/src/main/groovy/org/apache/camel/component/grape/GrapeCommand.groovy
@@ -0,0 +1,25 @@
+/**
+ * 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.camel.component.grape
+
+enum GrapeCommand {
+
+    grab,
+    listPatches,
+    clearPatches
+
+}
\ No newline at end of file

http://git-wip-us.apache.org/repos/asf/camel/blob/520295b2/components/camel-grape/src/main/groovy/org/apache/camel/component/grape/GrapeComponent.groovy
----------------------------------------------------------------------
diff --git a/components/camel-grape/src/main/groovy/org/apache/camel/component/grape/GrapeComponent.groovy
b/components/camel-grape/src/main/groovy/org/apache/camel/component/grape/GrapeComponent.groovy
new file mode 100644
index 0000000..a3d8d7b
--- /dev/null
+++ b/components/camel-grape/src/main/groovy/org/apache/camel/component/grape/GrapeComponent.groovy
@@ -0,0 +1,38 @@
+/**
+ * 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.camel.component.grape
+
+import org.apache.camel.impl.DefaultComponent
+
+class GrapeComponent extends DefaultComponent {
+
+    PatchesRepository patchesRepository = new FilePatchesRepository()
+
+    @Override
+    protected GrapeEndpoint createEndpoint(String uri, String remaining, Map<String, Object>
parameters) {
+        new GrapeEndpoint(uri, remaining, this)
+    }
+
+    PatchesRepository getPatchesRepository() {
+        return patchesRepository
+    }
+
+    void setPatchesRepository(PatchesRepository patchesRepository) {
+        this.patchesRepository = patchesRepository
+    }
+
+}

http://git-wip-us.apache.org/repos/asf/camel/blob/520295b2/components/camel-grape/src/main/groovy/org/apache/camel/component/grape/GrapeConstants.groovy
----------------------------------------------------------------------
diff --git a/components/camel-grape/src/main/groovy/org/apache/camel/component/grape/GrapeConstants.groovy
b/components/camel-grape/src/main/groovy/org/apache/camel/component/grape/GrapeConstants.groovy
new file mode 100644
index 0000000..c778674
--- /dev/null
+++ b/components/camel-grape/src/main/groovy/org/apache/camel/component/grape/GrapeConstants.groovy
@@ -0,0 +1,23 @@
+/**
+ * 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.camel.component.grape
+
+class GrapeConstants {
+
+    static final String GRAPE_COMMAND = 'CamelGrapeCommand'
+
+}

http://git-wip-us.apache.org/repos/asf/camel/blob/520295b2/components/camel-grape/src/main/groovy/org/apache/camel/component/grape/GrapeEndpoint.groovy
----------------------------------------------------------------------
diff --git a/components/camel-grape/src/main/groovy/org/apache/camel/component/grape/GrapeEndpoint.groovy
b/components/camel-grape/src/main/groovy/org/apache/camel/component/grape/GrapeEndpoint.groovy
new file mode 100644
index 0000000..0053b54
--- /dev/null
+++ b/components/camel-grape/src/main/groovy/org/apache/camel/component/grape/GrapeEndpoint.groovy
@@ -0,0 +1,70 @@
+/**
+ * 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.camel.component.grape
+
+import org.apache.camel.CamelContext
+import org.apache.camel.Consumer
+import org.apache.camel.Processor
+import org.apache.camel.Producer
+import org.apache.camel.impl.DefaultEndpoint
+
+import static groovy.grape.Grape.grab
+
+class GrapeEndpoint extends DefaultEndpoint {
+
+    private final String defaultCoordinates
+
+    GrapeEndpoint(String endpointUri, String defaultCoordinates, GrapeComponent component)
{
+        super(endpointUri, component)
+        this.defaultCoordinates = defaultCoordinates
+    }
+
+    static def loadPatches(CamelContext camelContext) {
+        def classLoader = camelContext.applicationContextClassLoader
+        def patchesRepository = camelContext.getComponent('grape', GrapeComponent.class).patchesRepository
+        patchesRepository.listPatches().each {
+            def coordinates = MavenCoordinates.parseMavenCoordinates(it)
+            grab(classLoader: classLoader,
+                    group: coordinates.groupId, module: coordinates.artifactId, version:
coordinates.version)
+        }
+    }
+
+    @Override
+    Producer createProducer() {
+        new GrapeProducer(this)
+    }
+
+    @Override
+    Consumer createConsumer(Processor processor) {
+        throw new UnsupportedOperationException('Grape component supports only the producer
side of the route.')
+    }
+
+    @Override
+    boolean isSingleton() {
+        true
+    }
+
+    String getDefaultCoordinates() {
+        defaultCoordinates
+    }
+
+    @Override
+    GrapeComponent getComponent() {
+        super.getComponent() as GrapeComponent
+    }
+
+}
\ No newline at end of file

http://git-wip-us.apache.org/repos/asf/camel/blob/520295b2/components/camel-grape/src/main/groovy/org/apache/camel/component/grape/GrapeProducer.groovy
----------------------------------------------------------------------
diff --git a/components/camel-grape/src/main/groovy/org/apache/camel/component/grape/GrapeProducer.groovy
b/components/camel-grape/src/main/groovy/org/apache/camel/component/grape/GrapeProducer.groovy
new file mode 100644
index 0000000..1e0f521
--- /dev/null
+++ b/components/camel-grape/src/main/groovy/org/apache/camel/component/grape/GrapeProducer.groovy
@@ -0,0 +1,68 @@
+/**
+ * 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.camel.component.grape
+
+import groovy.grape.Grape
+import org.apache.camel.Exchange
+import org.apache.camel.impl.DefaultProducer
+
+import static GrapeCommand.clearPatches
+import static GrapeCommand.grab
+import static GrapeCommand.listPatches
+import static GrapeConstants.GRAPE_COMMAND
+
+class GrapeProducer extends DefaultProducer {
+
+    GrapeProducer(GrapeEndpoint endpoint) {
+        super(endpoint)
+    }
+
+    @Override
+    void process(Exchange exchange) {
+        def command = exchange.in.getHeader(GRAPE_COMMAND, grab, GrapeCommand.class)
+        switch(command) {
+            case grab:
+                def classLoader = exchange.context.applicationContextClassLoader
+                def rawCoordinates = exchange.in.getBody(String.class)
+                try {
+                    def coordinates = MavenCoordinates.parseMavenCoordinates(rawCoordinates)
+                    Grape.grab(classLoader: classLoader, group: coordinates.groupId, module:
coordinates.artifactId, version: coordinates.version)
+                    endpoint.component.patchesRepository.install(rawCoordinates)
+                } catch (IllegalArgumentException ex) {
+                    def coordinates = MavenCoordinates.parseMavenCoordinates(getEndpoint().defaultCoordinates)
+                    Grape.grab(classLoader: classLoader, group: coordinates.groupId, module:
coordinates.artifactId, version: coordinates.version)
+                    endpoint.component.patchesRepository.install(getEndpoint().defaultCoordinates)
+                }
+                break
+
+            case listPatches:
+                def patches = endpoint.component.patchesRepository.listPatches()
+                exchange.getIn().setBody(patches)
+                break
+
+            case clearPatches:
+                endpoint.component.patchesRepository.clear()
+                break
+        }
+    }
+
+    @Override
+    GrapeEndpoint getEndpoint() {
+        super.getEndpoint() as GrapeEndpoint
+    }
+
+}

http://git-wip-us.apache.org/repos/asf/camel/blob/520295b2/components/camel-grape/src/main/groovy/org/apache/camel/component/grape/MavenCoordinates.groovy
----------------------------------------------------------------------
diff --git a/components/camel-grape/src/main/groovy/org/apache/camel/component/grape/MavenCoordinates.groovy
b/components/camel-grape/src/main/groovy/org/apache/camel/component/grape/MavenCoordinates.groovy
new file mode 100644
index 0000000..7959675
--- /dev/null
+++ b/components/camel-grape/src/main/groovy/org/apache/camel/component/grape/MavenCoordinates.groovy
@@ -0,0 +1,50 @@
+/**
+ * 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.camel.component.grape
+
+import groovy.transform.Immutable
+
+@Immutable
+class MavenCoordinates {
+
+    private final String groupId
+
+    private final String artifactId
+
+    private final String version
+
+    static MavenCoordinates parseMavenCoordinates(String coordinates) {
+        def coordinatesParts = coordinates.split('/')
+        if(coordinatesParts.length != 3) {
+            throw new IllegalArgumentException("Invalid coordinates: ${coordinates}")
+        }
+        new MavenCoordinates(groupId: coordinatesParts[0], artifactId: coordinatesParts[1],
version: coordinatesParts[2])
+    }
+
+    String getGroupId() {
+        return groupId
+    }
+
+    String getArtifactId() {
+        return artifactId
+    }
+
+    String getVersion() {
+        return version
+    }
+
+}

http://git-wip-us.apache.org/repos/asf/camel/blob/520295b2/components/camel-grape/src/main/groovy/org/apache/camel/component/grape/PatchesRepository.groovy
----------------------------------------------------------------------
diff --git a/components/camel-grape/src/main/groovy/org/apache/camel/component/grape/PatchesRepository.groovy
b/components/camel-grape/src/main/groovy/org/apache/camel/component/grape/PatchesRepository.groovy
new file mode 100644
index 0000000..e5f9ce0
--- /dev/null
+++ b/components/camel-grape/src/main/groovy/org/apache/camel/component/grape/PatchesRepository.groovy
@@ -0,0 +1,27 @@
+/**
+ * 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.camel.component.grape
+
+interface PatchesRepository {
+
+    void install(String coordinates);
+
+    List<String> listPatches();
+
+    void clear();
+
+}
\ No newline at end of file

http://git-wip-us.apache.org/repos/asf/camel/blob/520295b2/components/camel-grape/src/main/resources/META-INF/services/org/apache/camel/component/grape
----------------------------------------------------------------------
diff --git a/components/camel-grape/src/main/resources/META-INF/services/org/apache/camel/component/grape
b/components/camel-grape/src/main/resources/META-INF/services/org/apache/camel/component/grape
new file mode 100644
index 0000000..747706a
--- /dev/null
+++ b/components/camel-grape/src/main/resources/META-INF/services/org/apache/camel/component/grape
@@ -0,0 +1,17 @@
+#
+# 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.
+
+class=org.apache.camel.component.grape.GrapeComponent
\ No newline at end of file

http://git-wip-us.apache.org/repos/asf/camel/blob/520295b2/components/camel-grape/src/test/groovy/org/apache/camel/component/grape/GrapeComponentTest.groovy
----------------------------------------------------------------------
diff --git a/components/camel-grape/src/test/groovy/org/apache/camel/component/grape/GrapeComponentTest.groovy
b/components/camel-grape/src/test/groovy/org/apache/camel/component/grape/GrapeComponentTest.groovy
new file mode 100644
index 0000000..15bbee6
--- /dev/null
+++ b/components/camel-grape/src/test/groovy/org/apache/camel/component/grape/GrapeComponentTest.groovy
@@ -0,0 +1,100 @@
+/**
+ * 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.camel.component.grape
+
+import org.apache.camel.ServiceStatus
+import org.apache.camel.builder.RouteBuilder
+import org.apache.camel.component.grape.FilePatchesRepository
+import org.apache.camel.impl.DefaultCamelContext
+import org.junit.Assert
+import org.junit.Before
+import org.junit.Test
+
+import static org.apache.camel.component.grape.GrapeEndpoint.loadPatches
+import static org.apache.camel.ServiceStatus.Stopped
+
+class GrapeComponentTest extends Assert {
+
+    def pathesRepository = new FilePatchesRepository()
+
+    def camelContext = new DefaultCamelContext()
+
+    @Before
+    void before() {
+        camelContext.setApplicationContextClassLoader(new GroovyClassLoader())
+    }
+
+    @Test
+    void shouldLoadStreamComponent() {
+        pathesRepository.clear()
+        camelContext.start()
+        camelContext.createProducerTemplate().sendBody('grape:org.apache.camel/camel-stream/2.15.2',
'msg')
+        camelContext.createProducerTemplate().sendBody('stream:out', 'msg')
+    }
+
+    @Test
+    void shouldLoadStreamComponentViaBodyRequest() {
+        pathesRepository.clear()
+        camelContext.start()
+        camelContext.createProducerTemplate().sendBody('grape:grape', 'org.apache.camel/camel-stream/2.15.2')
+        camelContext.createProducerTemplate().sendBody('stream:out', 'msg')
+    }
+
+    @Test
+    void shouldLoadBeanAtRuntime() {
+        pathesRepository.clear()
+        camelContext.start()
+        camelContext.createProducerTemplate().sendBody('grape:grape', 'org.apache.camel/camel-stream/2.15.2')
+        def status = camelContext.createProducerTemplate().requestBody('bean:org.apache.camel.component.stream.StreamComponent?method=getStatus',
null, ServiceStatus.class)
+        assertEquals(Stopped, status)
+    }
+
+    @Test
+    void shouldLoadPatchesAtStartup() {
+        // Given
+        pathesRepository.clear()
+        camelContext.start()
+        camelContext.createProducerTemplate().sendBody('grape:grape', 'org.apache.camel/camel-stream/2.15.2')
+        camelContext.stop()
+
+        camelContext = new DefaultCamelContext()
+        camelContext.setApplicationContextClassLoader(new GroovyClassLoader())
+        camelContext.addRoutes(new RouteBuilder() {
+            @Override
+            void configure() {
+                loadPatches(camelContext)
+            }
+        })
+
+        // When
+        camelContext.start()
+        def status = camelContext.createProducerTemplate().requestBody('bean:org.apache.camel.component.stream.StreamComponent?method=getStatus',
null, ServiceStatus.class)
+
+        // Then
+        assertEquals(Stopped, status)
+    }
+
+    @Test
+    void shouldListPatches() {
+        pathesRepository.clear()
+        camelContext.start()
+        camelContext.createProducerTemplate().sendBody('grape:grape', 'org.apache.camel/camel-stream/2.15.2')
+        def patches = pathesRepository.listPatches()
+        assertEquals(['org.apache.camel/camel-stream/2.15.2'], patches)
+    }
+
+}

http://git-wip-us.apache.org/repos/asf/camel/blob/520295b2/components/pom.xml
----------------------------------------------------------------------
diff --git a/components/pom.xml b/components/pom.xml
index 368c5b3..e364395 100644
--- a/components/pom.xml
+++ b/components/pom.xml
@@ -108,6 +108,7 @@
     <module>camel-google-drive</module>
     <module>camel-google-mail</module>
     <module>camel-gora</module>
+    <module>camel-grape</module>
     <module>camel-gson</module>
     <module>camel-guava-eventbus</module>
     <module>camel-guice</module>

http://git-wip-us.apache.org/repos/asf/camel/blob/520295b2/parent/pom.xml
----------------------------------------------------------------------
diff --git a/parent/pom.xml b/parent/pom.xml
index da80edc..9abd2b1 100644
--- a/parent/pom.xml
+++ b/parent/pom.xml
@@ -122,9 +122,9 @@
     <commons-vfs2-version>2.0</commons-vfs2-version>
     <concurrentlinkedhashmap.version>1.4.2</concurrentlinkedhashmap.version>
     <cobertura-maven-plugin-version>2.7</cobertura-maven-plugin-version>
-    <cxf-version>3.0.5</cxf-version>
+    <cxf-version>3.0.4</cxf-version>
     <cxf-version-range>[2.7,4.0)</cxf-version-range>
-    <cxf-xjc-utils-version>3.0.3</cxf-xjc-utils-version>
+    <cxf-xjc-utils-version>3.0.2</cxf-xjc-utils-version>
     <deltaspike-version>1.3.0</deltaspike-version>
     <derby-version>10.11.1.1</derby-version>
     <disruptor-version>3.3.2</disruptor-version>
@@ -230,6 +230,7 @@
     <isorelax-bundle-version>20050913_4</isorelax-bundle-version>
     <isorelax-version>20090621</isorelax-version>
     <isorelax-jaxp-bridge-version>1.1</isorelax-jaxp-bridge-version>
+    <ivy-version>2.4.0</ivy-version>
     <jini-version>2.1</jini-version>
     <jackson-version>1.9.12</jackson-version>
     <jackson2-version>2.5.1</jackson2-version>
@@ -304,7 +305,7 @@
     <junit-version>4.11</junit-version>
     <jython-version>2.5.3</jython-version>
     <jzlib-version>1.1.3</jzlib-version>
-    <kafka-version>0.8.2.1</kafka-version>
+    <kafka-version>0.8.2.0</kafka-version>
     <kafka-bundle-version>0.8.2.0_1</kafka-bundle-version>
     <karaf-version>2.4.2</karaf-version>
     <karaf3-version>3.0.2</karaf3-version>
@@ -315,6 +316,7 @@
     <!-- virtual dependency only used by Eclipse m2e -->
     <lifecycle-mapping-version>1.0.0</lifecycle-mapping-version>
     <log4j-version>1.2.17</log4j-version>
+    <logback-version>1.1.2</logback-version>
     <lucene3-bundle-version>3.6.0_1</lucene3-bundle-version>
     <lucene3-version>3.6.0</lucene3-version>
     <lucene-bundle-version>4.10.3_1</lucene-bundle-version>


Mime
View raw message