FCREPO-3753

fcrepo-camel-toolbox-app/pom.xml

@@ -32,6 +32,12 @@
       <version>${project.parent.version}</version>
     </dependency>
 
+    <dependency>
+      <groupId>${project.parent.groupId}</groupId>
+      <artifactId>fcrepo-indexing-http</artifactId>
+      <version>${project.parent.version}</version>
+    </dependency>
+
     <dependency>
       <groupId>${project.parent.groupId}</groupId>
       <artifactId>fcrepo-reindexing</artifactId>

fcrepo-indexing-http/pom.xml

@@ -0,0 +1,110 @@
+<?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">
+
+  <modelVersion>4.0.0</modelVersion>
+
+  <parent>
+    <artifactId>fcrepo-camel-toolbox</artifactId>
+    <groupId>org.fcrepo.camel</groupId>
+    <version>6.0.0-SNAPSHOT</version>
+  </parent>
+
+  <artifactId>fcrepo-indexing-http</artifactId>
+  <packaging>jar</packaging>
+
+  <name>Fedora Indexing Service with a Http backend</name>
+  <description>Camel-based indexing service for Http</description>
+
+  <properties>
+  </properties>
+
+  <dependencies>
+    <dependency>
+      <groupId>org.apache.camel</groupId>
+      <artifactId>camel-core</artifactId>
+    </dependency>
+
+    <dependency>
+      <groupId>org.apache.camel</groupId>
+      <artifactId>camel-spring-javaconfig</artifactId>
+    </dependency>
+
+    <dependency>
+      <groupId>org.apache.camel</groupId>
+      <artifactId>camel-http</artifactId>
+    </dependency>
+
+    <dependency>
+      <groupId>org.apache.camel</groupId>
+      <artifactId>camel-mustache</artifactId>
+    </dependency>
+
+    <dependency>
+      <groupId>org.fcrepo.camel</groupId>
+      <artifactId>fcrepo-camel</artifactId>
+    </dependency>
+
+    <dependency>
+      <groupId>org.fcrepo.client</groupId>
+      <artifactId>fcrepo-java-client</artifactId>
+    </dependency>
+
+    <dependency>
+      <groupId>${project.parent.groupId}</groupId>
+      <artifactId>fcrepo-camel-common</artifactId>
+      <version>${project.parent.version}</version>
+    </dependency>
+
+    <!-- logging -->
+    <dependency>
+      <groupId>org.slf4j</groupId>
+      <artifactId>slf4j-api</artifactId>
+    </dependency>
+    <dependency>
+      <groupId>ch.qos.logback</groupId>
+      <artifactId>logback-classic</artifactId>
+    </dependency>
+
+    <!-- Testing & Camel Plugin -->
+    <dependency>
+      <groupId>org.apache.camel</groupId>
+      <artifactId>camel-test-spring</artifactId>
+    </dependency>
+
+    <dependency>
+      <groupId>commons-io</groupId>
+      <artifactId>commons-io</artifactId>
+      <scope>test</scope>
+    </dependency>
+
+    <dependency>
+      <groupId>xerces</groupId>
+      <artifactId>xercesImpl</artifactId>
+    </dependency>
+
+  </dependencies>
+
+  <build>
+    <defaultGoal>install</defaultGoal>
+
+    <plugins>
+
+      <plugin>
+        <groupId>org.apache.maven.plugins</groupId>
+        <artifactId>maven-compiler-plugin</artifactId>
+      </plugin>
+
+      <!--plugin>
+        <groupId>org.apache.maven.plugins</groupId>
+        <artifactId>maven-checkstyle-plugin</artifactId>
+      </plugin-->
+
+      <plugin>
+        <groupId>org.apache.maven.plugins</groupId>
+        <artifactId>maven-resources-plugin</artifactId>
+      </plugin>
+
+      <!-- to generate the MANIFEST-FILE of the bundle -->
+    </plugins>
+  </build>
+</project>

fcrepo-indexing-http/src/main/java/org/fcrepo/camel/indexing/http/FcrepoHttpIndexerConfig.java

@@ -0,0 +1,85 @@
+/*
+ * Licensed to DuraSpace under one or more contributor license agreements.
+ * See the NOTICE file distributed with this work for additional information
+ * regarding copyright ownership.
+ *
+ * DuraSpace 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.fcrepo.camel.indexing.http;
+
+import org.apache.camel.builder.RouteBuilder;
+import org.apache.camel.component.http.HttpComponent;
+import org.fcrepo.camel.common.config.BasePropsConfig;
+import org.fcrepo.camel.common.config.ConditionOnPropertyTrue;
+import org.springframework.beans.factory.annotation.Value;
+import org.springframework.context.annotation.Bean;
+import org.springframework.context.annotation.Conditional;
+import org.springframework.context.annotation.Configuration;
+
+/**
+ * A configuration class for the Http Indexer service
+ *
+ * @author Geoff Scholl, Demian Katz
+ */
+@Configuration
+@Conditional(FcrepoHttpIndexerConfig.HttpIndexerEnabled.class)
+public class FcrepoHttpIndexerConfig extends BasePropsConfig {
+
+    static final String HTTP_INDEXER_ENABLED = "http.indexer.enabled";
+
+    static class HttpIndexerEnabled extends ConditionOnPropertyTrue {
+        HttpIndexerEnabled() {
+            super(FcrepoHttpIndexerConfig.HTTP_INDEXER_ENABLED, false);
+        }
+    }
+
+    @Value("${input.stream:broker:topic:fedora}")
+    private String inputStream;
+
+    @Value("${http.reindex.stream:broker:queue:http.reindex}")
+    private String reindexStream;
+
+    @Value("${filter.containers:http://localhost:8080/fcrepo/rest/audit}")
+    private String filterContainers;
+
+    @Value("${http.baseUrl:http://localhost:8983/http/collection1}")
+    private String httpBaseUrl;
+
+    public String getInputStream() {
+        return inputStream;
+    }
+
+    public String getReindexStream() {
+        return reindexStream;
+    }
+
+    public String getHttpBaseUrl() {
+        return httpBaseUrl;
+    }
+
+
+    @Bean(name = "http")
+    public HttpComponent http() {
+        return new HttpComponent();
+    }
+
+    @Bean(name = "https")
+    public HttpComponent https() {
+        return new HttpComponent();
+    }
+
+    @Bean
+    public RouteBuilder httpRoute() {
+        return new HttpRouter();
+    }
+}

fcrepo-indexing-http/src/main/java/org/fcrepo/camel/indexing/http/HttpRouter.java

@@ -0,0 +1,82 @@
+/*
+ * Licensed to DuraSpace under one or more contributor license agreements.
+ * See the NOTICE file distributed with this work for additional information
+ * regarding copyright ownership.
+ *
+ * DuraSpace 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.fcrepo.camel.indexing.http;
+
+import org.apache.camel.LoggingLevel;
+import org.apache.camel.builder.RouteBuilder;
+import org.apache.camel.support.builder.Namespaces;
+import org.fcrepo.camel.processor.EventProcessor;
+import org.slf4j.Logger;
+import org.springframework.beans.factory.annotation.Autowired;
+
+import static org.apache.camel.Exchange.HTTP_METHOD;
+import static org.slf4j.LoggerFactory.getLogger;
+
+/**
+ * A content router for handling JMS events.
+ *
+ * @author Geoff Scholl, Demian Katz
+ */
+public class HttpRouter extends RouteBuilder {
+
+    private static final Logger logger = getLogger(HttpRouter.class);
+
+    @Autowired
+    private FcrepoHttpIndexerConfig config;
+
+    /**
+     * Configure the message route workflow.
+     */
+    public void configure() throws Exception {
+
+        final Namespaces ns = new Namespaces("rdf", "http://www.w3.org/1999/02/22-rdf-syntax-ns#");
+        ns.add("indexing", "http://fedora.info/definitions/v4/indexing#");
+        ns.add("ldp", "http://www.w3.org/ns/ldp#");
+
+        /*
+         * A generic error handler (specific to this RouteBuilder)
+         */
+        onException(Exception.class)
+            .maximumRedeliveries(config.getMaxRedeliveries())
+            .log("Index Routing Error: ${routeId}");
+
+        /*
+         * route a message to the proper queue
+         */
+        from(config.getInputStream())
+            .routeId("FcrepoHttpRouter")
+            .process(new EventProcessor())
+            .log(LoggingLevel.TRACE, "Received message from Fedora routing to index.http")
+            .to("direct:send.to.http");
+
+        /*
+         * Handle re-index events
+         */
+        from(config.getReindexStream())
+            .routeId("FcrepoHttpReindex")
+            .to("direct:send.to.http");
+
+        /*
+         * Forward message to Http
+         */
+        from("direct:send.to.http").routeId("FcrepoHttpSend")
+            .log(LoggingLevel.INFO, logger, "sending to http...")
+            .setHeader(HTTP_METHOD).constant("POST")
+            .to(config.getHttpBaseUrl());
+    }
+}

pom.xml

@@ -83,6 +83,7 @@
     <module>fcrepo-indexing-triplestore</module>
     <module>fcrepo-reindexing</module>
     <module>fcrepo-indexing-solr</module>
+    <module>fcrepo-indexing-http</module>
     <module>fcrepo-service-activemq</module>
     <module>fcrepo-service-camel</module>
     <module>fcrepo-ldpath</module>