You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@stanbol.apache.org by fl...@apache.org on 2012/06/19 00:58:59 UTC
svn commit: r1351527 - in
/incubator/stanbol/branches/cameltrial/flow/cameljobmanager: ./ src/
src/main/ src/main/java/ src/main/java/org/ src/main/java/org/apache/
src/main/java/org/apache/stanbol/ src/main/java/org/apache/stanbol/flow/
src/main/java/...
Author: florent
Date: Mon Jun 18 22:58:57 2012
New Revision: 1351527
URL: http://svn.apache.org/viewvc?rev=1351527&view=rev
Log:
missing module
Added:
incubator/stanbol/branches/cameltrial/flow/cameljobmanager/ (with props)
incubator/stanbol/branches/cameltrial/flow/cameljobmanager/pom.xml
incubator/stanbol/branches/cameltrial/flow/cameljobmanager/src/
incubator/stanbol/branches/cameltrial/flow/cameljobmanager/src/main/
incubator/stanbol/branches/cameltrial/flow/cameljobmanager/src/main/java/
incubator/stanbol/branches/cameltrial/flow/cameljobmanager/src/main/java/org/
incubator/stanbol/branches/cameltrial/flow/cameljobmanager/src/main/java/org/apache/
incubator/stanbol/branches/cameltrial/flow/cameljobmanager/src/main/java/org/apache/stanbol/
incubator/stanbol/branches/cameltrial/flow/cameljobmanager/src/main/java/org/apache/stanbol/flow/
incubator/stanbol/branches/cameltrial/flow/cameljobmanager/src/main/java/org/apache/stanbol/flow/cameljobmanager/
incubator/stanbol/branches/cameltrial/flow/cameljobmanager/src/main/java/org/apache/stanbol/flow/cameljobmanager/StanbolConverter.java
incubator/stanbol/branches/cameltrial/flow/cameljobmanager/src/main/java/org/apache/stanbol/flow/cameljobmanager/converter/
incubator/stanbol/branches/cameltrial/flow/cameljobmanager/src/main/java/org/apache/stanbol/flow/cameljobmanager/converter/FromContentItemConverter.java
incubator/stanbol/branches/cameltrial/flow/cameljobmanager/src/main/java/org/apache/stanbol/flow/cameljobmanager/engineprotocol/
incubator/stanbol/branches/cameltrial/flow/cameljobmanager/src/main/java/org/apache/stanbol/flow/cameljobmanager/engineprotocol/EngineComponent.java
incubator/stanbol/branches/cameltrial/flow/cameljobmanager/src/main/java/org/apache/stanbol/flow/cameljobmanager/engineprotocol/EngineConsumer.java
incubator/stanbol/branches/cameltrial/flow/cameljobmanager/src/main/java/org/apache/stanbol/flow/cameljobmanager/engineprotocol/EngineEndpoint.java
incubator/stanbol/branches/cameltrial/flow/cameljobmanager/src/main/java/org/apache/stanbol/flow/cameljobmanager/engineprotocol/EngineProducer.java
incubator/stanbol/branches/cameltrial/flow/cameljobmanager/src/main/java/org/apache/stanbol/flow/cameljobmanager/impl/
incubator/stanbol/branches/cameltrial/flow/cameljobmanager/src/main/java/org/apache/stanbol/flow/cameljobmanager/impl/CamelJobManager.java
incubator/stanbol/branches/cameltrial/flow/cameljobmanager/src/main/resources/
incubator/stanbol/branches/cameltrial/flow/cameljobmanager/src/main/resources/META-INF/
incubator/stanbol/branches/cameltrial/flow/cameljobmanager/src/main/resources/META-INF/services/
incubator/stanbol/branches/cameltrial/flow/cameljobmanager/src/main/resources/META-INF/services/org/
incubator/stanbol/branches/cameltrial/flow/cameljobmanager/src/main/resources/META-INF/services/org/apache/
incubator/stanbol/branches/cameltrial/flow/cameljobmanager/src/main/resources/META-INF/services/org/apache/camel/
incubator/stanbol/branches/cameltrial/flow/cameljobmanager/src/main/resources/META-INF/services/org/apache/camel/TypeConverter
incubator/stanbol/branches/cameltrial/flow/cameljobmanager/src/main/resources/META-INF/services/org/apache/camel/component/
incubator/stanbol/branches/cameltrial/flow/cameljobmanager/src/main/resources/META-INF/services/org/apache/camel/component/engine
incubator/stanbol/branches/cameltrial/flow/cameljobmanager/src/main/resources/log4j.properties
incubator/stanbol/branches/cameltrial/flow/cameljobmanager/src/test/
incubator/stanbol/branches/cameltrial/flow/cameljobmanager/src/test/java/
Propchange: incubator/stanbol/branches/cameltrial/flow/cameljobmanager/
------------------------------------------------------------------------------
--- svn:ignore (added)
+++ svn:ignore Mon Jun 18 22:58:57 2012
@@ -0,0 +1,11 @@
+target
+bin
+*.iml
+*.ipr
+*.iws
+.settings
+.project
+.classpath
+.externalToolBuilders
+maven-eclipse.xml
+.metadata
Added: incubator/stanbol/branches/cameltrial/flow/cameljobmanager/pom.xml
URL: http://svn.apache.org/viewvc/incubator/stanbol/branches/cameltrial/flow/cameljobmanager/pom.xml?rev=1351527&view=auto
==============================================================================
--- incubator/stanbol/branches/cameltrial/flow/cameljobmanager/pom.xml (added)
+++ incubator/stanbol/branches/cameltrial/flow/cameljobmanager/pom.xml Mon Jun 18 22:58:57 2012
@@ -0,0 +1,162 @@
+<?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.stanbol</groupId>
+ <artifactId>org.apache.stanbol.flow.reactor</artifactId>
+ <version>0.9.0-incubating-SNAPSHOT</version>
+ <relativePath>../</relativePath>
+ </parent>
+
+ <artifactId>org.apache.stanbol.flow.cameljobmanager</artifactId>
+ <packaging>bundle</packaging>
+
+ <name>Apache Stanbol Flow : Camel integration </name>
+ <description>
+ Contains all base classes for defining Stanbol-Camel protocols, transformer,...
+ TODO : rename is module with a more accurate name.
+ </description>
+
+ <inceptionYear>2011</inceptionYear>
+
+ <!-- TODO : update and uncomment this -->
+ <scm>
+ <connection>
+ scm:svn:http://svn.apache.org/repos/asf/incubator/stanbol/trunk/enhancer/jobmanager/cameljobmanager/chainjobmanager
+ </connection>
+ <developerConnection>
+ scm:svn:https://svn.apache.org/repos/asf/incubator/stanbol/trunk/enhancer/jobmanager/cameljobmanager/chainjobmanager
+ </developerConnection>
+ <url>http://incubator.apache.org/stanbol/</url>
+ </scm>
+
+
+
+ <properties>
+ <camel-version>2.8.1</camel-version>
+ </properties>
+
+ <dependencies>
+ <!-- API definition -->
+ <dependency>
+ <groupId>org.apache.stanbol</groupId>
+ <artifactId>org.apache.stanbol.flow.servicesapi</artifactId>
+ </dependency>
+
+
+ <dependency>
+ <groupId>commons-io</groupId>
+ <artifactId>commons-io</artifactId>
+ </dependency>
+
+ <!-- for test with @activate methods -->
+ <!-- TODO : remove version number on osgi stuff. But that version are because
+ of the FrameworkUtil.getBundle in FromContentItemConverter -->
+ <!-- this technik to get bundle is used as @reference on the Clerezza serializer
+ allways return null... -->
+ <dependency>
+ <groupId>org.osgi</groupId>
+ <artifactId>org.osgi.compendium</artifactId>
+ <version>4.2.0</version>
+ </dependency>
+
+ <dependency>
+ <groupId>org.osgi</groupId>
+ <artifactId>org.osgi.core</artifactId>
+ <version>4.2.0</version>
+ </dependency>
+
+ <!-- TODO : supprimer cette dependencie lorsque test des converter ok -->
+ <!-- <dependency> <groupId>javax.mail</groupId> <artifactId>mail</artifactId>
+ <version>1.4.4</version> </dependency> -->
+
+ <!-- dependencies for serialization -->
+ <dependency>
+ <groupId>javax.servlet</groupId>
+ <artifactId>servlet-api</artifactId>
+ </dependency>
+ <dependency>
+ <groupId>org.apache.clerezza</groupId>
+ <artifactId>rdf.core</artifactId>
+ </dependency>
+ <dependency>
+ <groupId>org.apache.stanbol</groupId>
+ <artifactId>org.apache.stanbol.commons.web.base</artifactId>
+ </dependency>
+ <dependency>
+ <groupId>com.sun.jersey</groupId>
+ <artifactId>jersey-core</artifactId>
+ </dependency>
+
+ <!-- Camel dependencies -->
+ <dependency>
+ <groupId>org.apache.camel</groupId>
+ <artifactId>camel-core-osgi</artifactId>
+ <version>${camel-version}</version>
+ </dependency>
+
+ <!-- Stanbol dependencies -->
+ <dependency>
+ <groupId>org.apache.stanbol</groupId>
+ <artifactId>org.apache.stanbol.enhancer.servicesapi</artifactId>
+ </dependency>
+
+ <dependency>
+ <groupId>org.apache.felix</groupId>
+ <artifactId>org.apache.felix.scr.annotations</artifactId>
+ </dependency>
+
+ <!-- for testing -->
+ <dependency>
+ <groupId>junit</groupId>
+ <artifactId>junit</artifactId>
+ <version>4.8.1</version>
+ <scope>test</scope>
+ </dependency>
+ <dependency>
+ <groupId>org.apache.camel</groupId>
+ <artifactId>camel-test</artifactId>
+ <version>${camel-version}</version>
+ <scope>test</scope>
+ </dependency>
+ </dependencies>
+
+ <build>
+ <defaultGoal>install</defaultGoal>
+
+ <plugins>
+ <!-- <plugin> <groupId>org.apache.maven.plugins</groupId> <artifactId>maven-compiler-plugin</artifactId>
+ <configuration> <source>1.5</source> <target>1.5</target> </configuration>
+ </plugin> -->
+
+ <plugin>
+ <groupId>org.apache.felix</groupId>
+ <artifactId>maven-bundle-plugin</artifactId>
+ <extensions>true</extensions>
+ <configuration>
+ <instructions>
+ <DynamicImport-Package>*</DynamicImport-Package>
+ </instructions>
+ </configuration>
+ </plugin>
+ <plugin>
+ <groupId>org.apache.felix</groupId>
+ <artifactId>maven-scr-plugin</artifactId>
+ </plugin>
+
+ </plugins>
+ </build>
+</project>
Added: incubator/stanbol/branches/cameltrial/flow/cameljobmanager/src/main/java/org/apache/stanbol/flow/cameljobmanager/StanbolConverter.java
URL: http://svn.apache.org/viewvc/incubator/stanbol/branches/cameltrial/flow/cameljobmanager/src/main/java/org/apache/stanbol/flow/cameljobmanager/StanbolConverter.java?rev=1351527&view=auto
==============================================================================
--- incubator/stanbol/branches/cameltrial/flow/cameljobmanager/src/main/java/org/apache/stanbol/flow/cameljobmanager/StanbolConverter.java (added)
+++ incubator/stanbol/branches/cameltrial/flow/cameljobmanager/src/main/java/org/apache/stanbol/flow/cameljobmanager/StanbolConverter.java Mon Jun 18 22:58:57 2012
@@ -0,0 +1,5 @@
+package org.apache.stanbol.flow.cameljobmanager;
+
+public interface StanbolConverter {
+
+}
Added: incubator/stanbol/branches/cameltrial/flow/cameljobmanager/src/main/java/org/apache/stanbol/flow/cameljobmanager/converter/FromContentItemConverter.java
URL: http://svn.apache.org/viewvc/incubator/stanbol/branches/cameltrial/flow/cameljobmanager/src/main/java/org/apache/stanbol/flow/cameljobmanager/converter/FromContentItemConverter.java?rev=1351527&view=auto
==============================================================================
--- incubator/stanbol/branches/cameltrial/flow/cameljobmanager/src/main/java/org/apache/stanbol/flow/cameljobmanager/converter/FromContentItemConverter.java (added)
+++ incubator/stanbol/branches/cameltrial/flow/cameljobmanager/src/main/java/org/apache/stanbol/flow/cameljobmanager/converter/FromContentItemConverter.java Mon Jun 18 22:58:57 2012
@@ -0,0 +1,78 @@
+package org.apache.stanbol.flow.cameljobmanager.converter;
+
+import java.io.ByteArrayInputStream;
+import java.io.ByteArrayOutputStream;
+import java.io.IOException;
+import java.io.InputStream;
+import java.io.UnsupportedEncodingException;
+
+
+import org.apache.camel.Converter;
+import org.apache.camel.Exchange;
+import org.apache.camel.TypeConverter;
+import org.apache.camel.component.file.GenericFile;
+import org.apache.camel.spi.TypeConverterRegistry;
+import org.apache.clerezza.rdf.core.serializedform.Serializer;
+import org.apache.felix.scr.annotations.Component;
+import org.apache.stanbol.enhancer.servicesapi.ContentItem;
+import org.apache.stanbol.enhancer.servicesapi.helper.InMemoryContentItem;
+import org.osgi.framework.BundleContext;
+import org.osgi.framework.FrameworkUtil;
+import org.osgi.framework.ServiceReference;
+
+@Component(immediate = true, metatype = true)
+@Converter
+public final class FromContentItemConverter {
+
+ //TODO : see how to fix a global default mediatype for all stanbol app
+ public static String defaultMediaType = "application/rdf+xml";
+ //"text/turtle";
+
+ public FromContentItemConverter(){}
+
+ //TODO : see why the Reference annotation for serializer always return a null object
+ // if solution found remove FrameworkUtil retrieving.
+ public Serializer serializer;
+
+
+ @Converter
+ public ByteArrayOutputStream contentItemToByteArrayOutputStream(ContentItem ci, Exchange exchange) throws UnsupportedEncodingException, IOException{
+ ByteArrayOutputStream out = new ByteArrayOutputStream();
+
+ BundleContext bundleContext = FrameworkUtil.getBundle(FromContentItemConverter.class).getBundleContext();
+ serializer = null;
+ ServiceReference ref = bundleContext.getServiceReference(Serializer.class.getName());
+ if(ref != null){
+ serializer = (Serializer) bundleContext.getService(ref);
+ String mediatype = (String) exchange.getIn().getHeader("mediatype", defaultMediaType);
+ serializer.serialize(out, ci.getMetadata(), mediatype);
+ } else {
+ out.write("Error during body conversion, serviceReference is null.".getBytes());
+ }
+ return out;
+ }
+
+ @Converter
+ public InputStream contentItemToInputStream(ContentItem ci, Exchange exchange) throws UnsupportedEncodingException, IOException{
+ return new ByteArrayInputStream(contentItemToByteArrayOutputStream(ci, exchange).toByteArray());
+ }
+
+ @Converter
+ public ContentItem fromFileToCi(GenericFile file , Exchange exchange) throws UnsupportedEncodingException, IOException{
+
+ //TODO : use Tika mimeType detection capability in order to process any file format
+ String mimetype = "text/plain";
+
+ TypeConverterRegistry registry = exchange.getContext().getTypeConverterRegistry();
+ Class from = file.getBody().getClass();
+ TypeConverter tc = registry.lookup(byte[].class, from);
+ if (tc != null) {
+ Object body = file.getBody();
+ byte[] content = tc.convertTo(byte[].class, exchange, body);
+ return new InMemoryContentItem(content, mimetype);
+ }
+
+ return new InMemoryContentItem("Error during transformation".getBytes(), mimetype);
+ }
+
+}
Added: incubator/stanbol/branches/cameltrial/flow/cameljobmanager/src/main/java/org/apache/stanbol/flow/cameljobmanager/engineprotocol/EngineComponent.java
URL: http://svn.apache.org/viewvc/incubator/stanbol/branches/cameltrial/flow/cameljobmanager/src/main/java/org/apache/stanbol/flow/cameljobmanager/engineprotocol/EngineComponent.java?rev=1351527&view=auto
==============================================================================
--- incubator/stanbol/branches/cameltrial/flow/cameljobmanager/src/main/java/org/apache/stanbol/flow/cameljobmanager/engineprotocol/EngineComponent.java (added)
+++ incubator/stanbol/branches/cameltrial/flow/cameljobmanager/src/main/java/org/apache/stanbol/flow/cameljobmanager/engineprotocol/EngineComponent.java Mon Jun 18 22:58:57 2012
@@ -0,0 +1,83 @@
+/**
+ * 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.stanbol.flow.cameljobmanager.engineprotocol;
+
+import java.util.ArrayList;
+import java.util.Collections;
+import java.util.HashMap;
+import java.util.List;
+import java.util.Map;
+
+import org.apache.camel.Endpoint;
+import org.apache.camel.impl.DefaultComponent;
+import org.apache.stanbol.enhancer.servicesapi.EnhancementEngine;
+
+
+/**
+ * Naive EnhancementJobManager implementation that keeps its request queue in
+ * memory.
+ *
+ *
+ * @scr.component immediate="true"
+ * @scr.service
+ * @scr.reference name="EnhancementEngine"
+ * interface="org.apache.stanbol.enhancer.servicesapi.EnhancementEngine"
+ * cardinality="0..n" policy="dynamic"
+ *
+ */
+public class EngineComponent extends DefaultComponent {
+
+ private Map<String, EnhancementEngine> engineMap;
+
+ protected void bindEnhancementEngine(EnhancementEngine e) {
+ if (engineMap == null){
+ engineMap = new HashMap<String, EnhancementEngine>();
+ }
+ engineMap.put(e.getClass().getName(), e);
+ }
+
+ protected void unbindEnhancementEngine(EnhancementEngine e) {
+ engineMap.remove(e.getClass().getName());
+ }
+
+ public List<EnhancementEngine> getEnhancementEngines() {
+ return Collections.unmodifiableList(new ArrayList<EnhancementEngine>(engineMap.values()));
+ }
+
+ public EnhancementEngine getEnhancementEngine(String engineClassName){
+ return engineMap.get(engineClassName);
+ }
+
+ public void setEnhancementEngine(EnhancementEngine e){
+ bindEnhancementEngine(e);
+ }
+
+ protected Endpoint createEndpoint(String uri, String remaining, Map<String, Object> parameters) throws Exception {
+ Endpoint endpoint ;
+ EnhancementEngine e = getEnhancementEngine(remaining);
+
+ if (e != null){
+ endpoint = new EngineEndpoint(remaining, this, e);
+ }
+ else{
+ throw new UnsupportedOperationException("No registered engine referenced by this name : " + remaining);
+ }
+
+ setProperties(endpoint, parameters);
+ return endpoint;
+ }
+}
Added: incubator/stanbol/branches/cameltrial/flow/cameljobmanager/src/main/java/org/apache/stanbol/flow/cameljobmanager/engineprotocol/EngineConsumer.java
URL: http://svn.apache.org/viewvc/incubator/stanbol/branches/cameltrial/flow/cameljobmanager/src/main/java/org/apache/stanbol/flow/cameljobmanager/engineprotocol/EngineConsumer.java?rev=1351527&view=auto
==============================================================================
--- incubator/stanbol/branches/cameltrial/flow/cameljobmanager/src/main/java/org/apache/stanbol/flow/cameljobmanager/engineprotocol/EngineConsumer.java (added)
+++ incubator/stanbol/branches/cameltrial/flow/cameljobmanager/src/main/java/org/apache/stanbol/flow/cameljobmanager/engineprotocol/EngineConsumer.java Mon Jun 18 22:58:57 2012
@@ -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.stanbol.flow.cameljobmanager.engineprotocol;
+
+import org.apache.camel.Processor;
+import org.apache.camel.impl.ScheduledPollConsumer;
+
+/**
+ * The Engine consumer.
+ */
+public class EngineConsumer extends ScheduledPollConsumer {
+ private final EngineEndpoint endpoint;
+
+ public EngineConsumer(EngineEndpoint endpoint, Processor processor) {
+ super(endpoint, processor);
+ this.endpoint = endpoint;
+ }
+
+ @Override
+ protected int poll() throws Exception {
+ throw new UnsupportedOperationException("You cannot get messages from this endpoint: ");
+ }
+
+}
Added: incubator/stanbol/branches/cameltrial/flow/cameljobmanager/src/main/java/org/apache/stanbol/flow/cameljobmanager/engineprotocol/EngineEndpoint.java
URL: http://svn.apache.org/viewvc/incubator/stanbol/branches/cameltrial/flow/cameljobmanager/src/main/java/org/apache/stanbol/flow/cameljobmanager/engineprotocol/EngineEndpoint.java?rev=1351527&view=auto
==============================================================================
--- incubator/stanbol/branches/cameltrial/flow/cameljobmanager/src/main/java/org/apache/stanbol/flow/cameljobmanager/engineprotocol/EngineEndpoint.java (added)
+++ incubator/stanbol/branches/cameltrial/flow/cameljobmanager/src/main/java/org/apache/stanbol/flow/cameljobmanager/engineprotocol/EngineEndpoint.java Mon Jun 18 22:58:57 2012
@@ -0,0 +1,49 @@
+/**
+ * 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.stanbol.flow.cameljobmanager.engineprotocol;
+
+import org.apache.camel.Consumer;
+import org.apache.camel.Processor;
+import org.apache.camel.Producer;
+import org.apache.camel.impl.DefaultEndpoint;
+import org.apache.stanbol.enhancer.servicesapi.EnhancementEngine;
+
+
+public class EngineEndpoint extends DefaultEndpoint {
+
+ private EnhancementEngine engine;
+
+ public EngineEndpoint(String uri, EngineComponent component, EnhancementEngine e) {
+ super(uri, component);
+ this.engine = e;
+ }
+
+ public EnhancementEngine getEngine(){
+ return engine;
+ }
+ public Producer createProducer() throws Exception {
+ return new EngineProducer(this);
+ }
+
+ public Consumer createConsumer(Processor processor) throws Exception {
+ throw new UnsupportedOperationException("You cannot get messages from this endpoint: " + getEndpointUri());
+ }
+
+ public boolean isSingleton() {
+ return true;
+ }
+}
Added: incubator/stanbol/branches/cameltrial/flow/cameljobmanager/src/main/java/org/apache/stanbol/flow/cameljobmanager/engineprotocol/EngineProducer.java
URL: http://svn.apache.org/viewvc/incubator/stanbol/branches/cameltrial/flow/cameljobmanager/src/main/java/org/apache/stanbol/flow/cameljobmanager/engineprotocol/EngineProducer.java?rev=1351527&view=auto
==============================================================================
--- incubator/stanbol/branches/cameltrial/flow/cameljobmanager/src/main/java/org/apache/stanbol/flow/cameljobmanager/engineprotocol/EngineProducer.java (added)
+++ incubator/stanbol/branches/cameltrial/flow/cameljobmanager/src/main/java/org/apache/stanbol/flow/cameljobmanager/engineprotocol/EngineProducer.java Mon Jun 18 22:58:57 2012
@@ -0,0 +1,47 @@
+/**
+ * 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.stanbol.flow.cameljobmanager.engineprotocol;
+
+import org.apache.camel.Exchange;
+import org.apache.camel.TypeConverter;
+import org.apache.camel.impl.DefaultProducer;
+import org.apache.camel.spi.TypeConverterRegistry;
+import org.apache.stanbol.enhancer.servicesapi.ContentItem;
+import org.apache.stanbol.enhancer.servicesapi.EnhancementEngine;
+import org.apache.stanbol.enhancer.servicesapi.helper.InMemoryContentItem;
+
+public class EngineProducer extends DefaultProducer {
+ private EngineEndpoint endpoint;
+
+ public EngineProducer(EngineEndpoint endpoint) {
+ super(endpoint);
+ this.endpoint = endpoint;
+ }
+
+ public void process(Exchange exchange) throws Exception {
+ ContentItem ci = exchange.getIn().getBody(ContentItem.class);
+
+ EnhancementEngine stanbolEngine = endpoint.getEngine();
+
+ if (stanbolEngine.canEnhance(ci) != EnhancementEngine.CANNOT_ENHANCE){
+ stanbolEngine.computeEnhancements(ci);
+ exchange.getIn().setBody(ci);
+ }
+
+ }
+
+}
Added: incubator/stanbol/branches/cameltrial/flow/cameljobmanager/src/main/java/org/apache/stanbol/flow/cameljobmanager/impl/CamelJobManager.java
URL: http://svn.apache.org/viewvc/incubator/stanbol/branches/cameltrial/flow/cameljobmanager/src/main/java/org/apache/stanbol/flow/cameljobmanager/impl/CamelJobManager.java?rev=1351527&view=auto
==============================================================================
--- incubator/stanbol/branches/cameltrial/flow/cameljobmanager/src/main/java/org/apache/stanbol/flow/cameljobmanager/impl/CamelJobManager.java (added)
+++ incubator/stanbol/branches/cameltrial/flow/cameljobmanager/src/main/java/org/apache/stanbol/flow/cameljobmanager/impl/CamelJobManager.java Mon Jun 18 22:58:57 2012
@@ -0,0 +1,123 @@
+package org.apache.stanbol.flow.cameljobmanager.impl;
+
+import java.io.IOException;
+import java.util.List;
+import java.util.Map.Entry;
+
+import org.apache.camel.CamelContext;
+import org.apache.camel.Component;
+import org.apache.camel.Endpoint;
+import org.apache.camel.ProducerTemplate;
+import org.apache.camel.RoutesBuilder;
+import org.apache.camel.builder.RouteBuilder;
+import org.apache.camel.core.osgi.OsgiDefaultCamelContext;
+import org.apache.camel.model.RouteDefinition;
+import org.apache.stanbol.enhancer.servicesapi.Chain;
+import org.apache.stanbol.enhancer.servicesapi.ChainException;
+import org.apache.stanbol.enhancer.servicesapi.ChainManager;
+import org.apache.stanbol.enhancer.servicesapi.ContentItem;
+import org.apache.stanbol.enhancer.servicesapi.EnhancementEngine;
+import org.apache.stanbol.enhancer.servicesapi.EnhancementException;
+import org.apache.stanbol.enhancer.servicesapi.FlowJobManager;
+import org.apache.stanbol.flow.cameljobmanager.engineprotocol.EngineComponent;
+import org.apache.felix.scr.annotations.Activate;
+import org.apache.felix.scr.annotations.Deactivate;
+import org.apache.felix.scr.annotations.Reference;
+import org.osgi.service.component.ComponentContext;
+
+
+/**
+ * Naive EnhancementJobManager implementation that keeps its request queue in
+ * memory.
+ *
+ * @scr.component immediate="true"
+ * @scr.service
+ *
+ * @scr.reference name="Ec"
+ * interface="org.apache.camel.Component"
+ * policy="dynamic"
+ *
+ *@scr.reference name="Route"
+ * interface="org.apache.camel.RoutesBuilder"
+ * cardinality="0..n" policy="dynamic"
+ */
+public class CamelJobManager implements FlowJobManager {
+
+ EngineComponent ec;
+
+ private CamelContext cContext = null;
+
+ @Reference
+ protected ChainManager chainManager;
+
+ protected void bindRoute(RoutesBuilder e) throws Exception {
+ RouteBuilder srb = (RouteBuilder)e;
+ cContext.addRoutes(srb);
+ for (RouteDefinition rd : srb.getRouteCollection().getRoutes() ){
+ cContext.startRoute(rd.getId());
+ }
+ }
+
+ /**
+ * Remove route for the Camel context
+ * @param e : The route builder
+ * @throws Exception
+ */
+ protected void unbindRoute(RoutesBuilder e) throws Exception {
+ RouteBuilder srb = (RouteBuilder)e;
+ for (RouteDefinition routeDefs : srb.getRouteCollection().getRoutes()){
+ cContext.stopRoute(routeDefs);
+ cContext.removeRouteDefinition(routeDefs);
+ }
+ }
+
+ protected void bindEc(Component e) {
+ ec= (EngineComponent)e;
+ }
+
+ protected void unbindEc(Component e) {
+ ec = null;
+ }
+
+ @Activate
+ public void activate(ComponentContext ce) throws IOException {
+ cContext = new OsgiDefaultCamelContext(ce.getBundleContext());
+
+ try {
+ cContext.addComponent("engine", ec);
+ cContext.start();
+ } catch (Exception e) {
+ throw new IOException(e);
+ }
+ }
+
+ @Deactivate
+ public void deactivate(ComponentContext ce) throws Exception {
+ cContext.stop();
+ }
+
+ @Override
+ public void enhanceContent(ContentItem ci) throws EnhancementException {
+ Chain defaultChain = chainManager.getDefault();
+ if(defaultChain == null){
+ throw new ChainException("Unable to enhance ContentItem '"+ci.getUri()+
+ "' because currently no enhancement chain is active. Please" +
+ "configure a Chain or enable the default chain");
+ }
+ enhanceContent(ci, defaultChain);
+ }
+
+ @Override
+ public void enhanceContent(ContentItem ci, Chain chain) throws EnhancementException {
+ //TODO : better integration with REST :
+ //http://camel.apache.org/cxfrs.html
+ ProducerTemplate tpl = cContext.createProducerTemplate();
+ ContentItem result = tpl.requestBody("direct://"+chain.getName(), ci, ContentItem.class);
+ }
+
+
+ public List<EnhancementEngine> getActiveEngines() {
+ return ec.getEnhancementEngines();
+ }
+
+}
Added: incubator/stanbol/branches/cameltrial/flow/cameljobmanager/src/main/resources/META-INF/services/org/apache/camel/TypeConverter
URL: http://svn.apache.org/viewvc/incubator/stanbol/branches/cameltrial/flow/cameljobmanager/src/main/resources/META-INF/services/org/apache/camel/TypeConverter?rev=1351527&view=auto
==============================================================================
--- incubator/stanbol/branches/cameltrial/flow/cameljobmanager/src/main/resources/META-INF/services/org/apache/camel/TypeConverter (added)
+++ incubator/stanbol/branches/cameltrial/flow/cameljobmanager/src/main/resources/META-INF/services/org/apache/camel/TypeConverter Mon Jun 18 22:58:57 2012
@@ -0,0 +1 @@
+org.apache.stanbol.flow.cameljobmanager.converter
Added: incubator/stanbol/branches/cameltrial/flow/cameljobmanager/src/main/resources/META-INF/services/org/apache/camel/component/engine
URL: http://svn.apache.org/viewvc/incubator/stanbol/branches/cameltrial/flow/cameljobmanager/src/main/resources/META-INF/services/org/apache/camel/component/engine?rev=1351527&view=auto
==============================================================================
--- incubator/stanbol/branches/cameltrial/flow/cameljobmanager/src/main/resources/META-INF/services/org/apache/camel/component/engine (added)
+++ incubator/stanbol/branches/cameltrial/flow/cameljobmanager/src/main/resources/META-INF/services/org/apache/camel/component/engine Mon Jun 18 22:58:57 2012
@@ -0,0 +1,18 @@
+#
+# 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=stanbolEngine.camelComponent.EngineComponent
Added: incubator/stanbol/branches/cameltrial/flow/cameljobmanager/src/main/resources/log4j.properties
URL: http://svn.apache.org/viewvc/incubator/stanbol/branches/cameltrial/flow/cameljobmanager/src/main/resources/log4j.properties?rev=1351527&view=auto
==============================================================================
--- incubator/stanbol/branches/cameltrial/flow/cameljobmanager/src/main/resources/log4j.properties (added)
+++ incubator/stanbol/branches/cameltrial/flow/cameljobmanager/src/main/resources/log4j.properties Mon Jun 18 22:58:57 2012
@@ -0,0 +1,22 @@
+
+#
+# The logging properties used for eclipse testing, We want to see debug output on the console.
+#
+log4j.rootLogger=INFO, out
+
+# uncomment the following line to turn on Camel debugging
+#log4j.logger.org.apache.camel=DEBUG
+
+# uncomment the following line to turn on ActiveMQ debugging
+#log4j.logger.org.apache.activemq=DEBUG
+
+log4j.logger.org.springframework=WARN
+
+
+# CONSOLE appender not used by default
+log4j.appender.out=org.apache.log4j.ConsoleAppender
+log4j.appender.out.layout=org.apache.log4j.PatternLayout
+log4j.appender.out.layout.ConversionPattern=[%30.30t] %-30.30c{1} %-5p %m%n
+#log4j.appender.out.layout.ConversionPattern=%d [%-15.15t] %-5p %-30.30c{1} - %m%n
+
+log4j.throwableRenderer=org.apache.log4j.EnhancedThrowableRenderer
\ No newline at end of file